Skip to content

Commit a4aa479

Browse files
committed
Report proper value when node became needed again
1 parent 3f86aa6 commit a4aa479

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

cluster-autoscaler/core/scaledown/latencytracker/node_latency_tracker.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,10 @@ func (t *NodeLatencyTracker) Process(autoscalingCtx *ca_context.AutoscalingConte
9494
nodeName := unremovableNode.Node.Name
9595
if info, exists := t.unneededNodes[nodeName]; exists {
9696
duration := time.Since(info.unneededSince)
97-
metrics.UpdateScaleDownNodeRemovalLatency(false, duration)
97+
latency := duration - info.removalThreshold
98+
if latency > 0 {
99+
metrics.UpdateScaleDownNodeRemovalLatency(false, latency)
100+
}
98101
klog.V(4).Infof("Node %q is unremovable, became needed again (unneeded for %s).", nodeName, duration)
99102
delete(t.unneededNodes, nodeName)
100103
}

0 commit comments

Comments
 (0)