Drop things from the queue when completed

rancher · Apr 16, 2020 · 19664dd · 19664dd
1 parent 4645d8d
commit 19664dd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/clustercache/controller.go b/pkg/clustercache/controller.go
@@ -216,6 +216,7 @@ func (h *clusterCache) List(gvr schema2.GroupVersionResource) []interface{} {
 }
 
 func (h *clusterCache) start() {
+	defer h.workqueue.ShutDown()
 	for {
 		eventObj, ok := h.workqueue.Get()
 		if ok {
@@ -247,6 +248,7 @@ func (h *clusterCache) start() {
 				logrus.Errorf("failed to handle remove event: %v", err)
 			}
 		}
+		h.workqueue.Done(eventObj)
 	}
 }