From c47a7c4e39e889edcb69b852778865cb29304fd4 Mon Sep 17 00:00:00 2001 From: Ketan Umare Date: Wed, 10 Jun 2020 11:23:25 -0700 Subject: [PATCH] Ratelimiting the number of times a workflow is consumed (#153) --- pkg/controller/controller.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go index 8c01755f2d..0c247f116d 100644 --- 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) {