From ea67cb9121310a92e5e8703dcaebf08c30b5c5c2 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) --- flytepropeller/pkg/controller/composite_workqueue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flytepropeller/pkg/controller/composite_workqueue.go b/flytepropeller/pkg/controller/composite_workqueue.go index a03e79e11..386f5a9dc 100644 --- a/flytepropeller/pkg/controller/composite_workqueue.go +++ b/flytepropeller/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)