Workqueue should add items using a rate limiter (flyteorg#151)

eapolinario · Jun 9, 2020 · 3bc48b0 · 3bc48b0
1 parent 03d1c1d
commit 3bc48b0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)