Merge pull request #886 from wzshiming/fix/alway-renew-leases

Fix always renew lease when disconnection from apiserver
kubernetes-sigs · Dec 27, 2023 · 2897931 · 2897931
2 parents 4181e21 + 4df634b
commit 2897931
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/kwok/controllers/node_lease_controller.go b/pkg/kwok/controllers/node_lease_controller.go
@@ -146,7 +146,10 @@ func (c *NodeLeaseController) syncWorker(ctx context.Context) {
 		now := c.clock.Now()
 		c.sync(ctx, nodeName)
 		nextTime := c.nextTryTime(nodeName, now)
-		_ = c.delayQueue.AddAfter(nodeName, nextTime.Sub(now))
+		dur := nextTime.Sub(now)
+		if dur > 0 {
+			_ = c.delayQueue.AddAfter(nodeName, dur)
+		}
 	}
 }