We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 62ced20 commit b6b46a0Copy full SHA for b6b46a0
staging/src/k8s.io/client-go/tools/leaderelection/leaderelection.go
@@ -304,7 +304,9 @@ func (le *LeaderElector) release() bool {
304
RenewTime: now,
305
AcquireTime: now,
306
}
307
- if err := le.config.Lock.Update(context.TODO(), leaderElectionRecord); err != nil {
+ timeoutCtx, timeoutCancel := context.WithTimeout(context.Background(), le.config.RenewDeadline)
308
+ defer timeoutCancel()
309
+ if err := le.config.Lock.Update(timeoutCtx, leaderElectionRecord); err != nil {
310
klog.Errorf("Failed to release lock: %v", err)
311
return false
312
0 commit comments