Skip to content

Commit

Permalink
Fix clearing rate limiter in disruption controller
Browse files Browse the repository at this point in the history
  • Loading branch information
mimowo committed Jan 3, 2023
1 parent c090810 commit cceaf6c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/controller/disruption/disruption.go
Original file line number Diff line number Diff line change
Expand Up @@ -648,7 +648,7 @@ func (dc *DisruptionController) processNextStalePodDisruptionWorkItem(ctx contex
defer dc.stalePodDisruptionQueue.Done(key)
err := dc.syncStalePodDisruption(ctx, key.(string))
if err == nil {
dc.queue.Forget(key)
dc.stalePodDisruptionQueue.Forget(key)
return true
}
utilruntime.HandleError(fmt.Errorf("error syncing Pod %v to clear DisruptionTarget condition, requeueing: %v", key.(string), err))
Expand Down

0 comments on commit cceaf6c

Please sign in to comment.