From 8448ee4e1246610cfbfe8f3e6d989311720d5f81 Mon Sep 17 00:00:00 2001 From: Jordan Liggitt Date: Thu, 21 Jun 2018 17:10:18 -0400 Subject: [PATCH] Remove item from taint manager workqueue on completion --- pkg/controller/nodelifecycle/scheduler/taint_manager.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/controller/nodelifecycle/scheduler/taint_manager.go b/pkg/controller/nodelifecycle/scheduler/taint_manager.go index 2388ac20f51..55aad9f63d8 100644 --- a/pkg/controller/nodelifecycle/scheduler/taint_manager.go +++ b/pkg/controller/nodelifecycle/scheduler/taint_manager.go @@ -224,9 +224,11 @@ func (tc *NoExecuteTaintManager) Run(stopCh <-chan struct{}) { hash := hash(nodeUpdate.name()) select { case <-stopCh: + tc.nodeUpdateQueue.Done(item) break case tc.nodeUpdateChannels[hash%workers] <- nodeUpdate: } + tc.nodeUpdateQueue.Done(item) } }(stopCh) @@ -240,9 +242,11 @@ func (tc *NoExecuteTaintManager) Run(stopCh <-chan struct{}) { hash := hash(podUpdate.nodeName()) select { case <-stopCh: + tc.podUpdateQueue.Done(item) break case tc.podUpdateChannels[hash%workers] <- podUpdate: } + tc.podUpdateQueue.Done(item) } }(stopCh)