From 3bc48b02cda24180af5e254836ca3c5600498a3b Mon Sep 17 00:00:00 2001 From: Ketan Umare Date: Tue, 9 Jun 2020 16:58:26 -0700 Subject: [PATCH] Workqueue should add items using a rate limiter (#151) --- pkg/controller/composite_workqueue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/controller/composite_workqueue.go b/pkg/controller/composite_workqueue.go index a03e79e115..386f5a9dcf 100644 --- a/pkg/controller/composite_workqueue.go +++ b/pkg/controller/composite_workqueue.go @@ -119,7 +119,7 @@ func (b *BatchingWorkQueue) runSubQueueHandler(ctx context.Context) { } for _, obj := range objectsRetrieved { - b.Add(obj) + b.AddRateLimited(obj) // Finally, if no error occurs we Forget this item so it does not // get queued again until another change happens. b.subQueue.Forget(obj)