mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 11:50:44 +00:00
Fix clearing rate limiter in disruption controller
This commit is contained in:
parent
4e70155dbd
commit
c3d0e8ff05
@ -648,7 +648,7 @@ func (dc *DisruptionController) processNextStalePodDisruptionWorkItem(ctx contex
|
|||||||
defer dc.stalePodDisruptionQueue.Done(key)
|
defer dc.stalePodDisruptionQueue.Done(key)
|
||||||
err := dc.syncStalePodDisruption(ctx, key.(string))
|
err := dc.syncStalePodDisruption(ctx, key.(string))
|
||||||
if err == nil {
|
if err == nil {
|
||||||
dc.queue.Forget(key)
|
dc.stalePodDisruptionQueue.Forget(key)
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
utilruntime.HandleError(fmt.Errorf("error syncing Pod %v to clear DisruptionTarget condition, requeueing: %v", key.(string), err))
|
utilruntime.HandleError(fmt.Errorf("error syncing Pod %v to clear DisruptionTarget condition, requeueing: %v", key.(string), err))
|
||||||
|
Loading…
Reference in New Issue
Block a user