Ratelimiting the number of times a workflow is consumed (flyteorg#153)

eapolinario · Jun 10, 2020 · c47a7c4 · c47a7c4
1 parent 3bc48b0
commit c47a7c4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -131,7 +131,7 @@ func (c *Controller) enqueueFlyteWorkflow(obj interface{}) {
 	}
 	key := wf.GetK8sWorkflowID()
 	logger.Infof(ctx, "==> Enqueueing workflow [%v]", key)
-	c.workQueue.Add(key.String())
+	c.workQueue.AddRateLimited(key.String())
 }
 
 func (c *Controller) enqueueWorkflowForNodeUpdates(wID v1alpha1.WorkflowID) {