Add items to work queue after Config.CreationDelay duration

stakater · Jun 21, 2019 · e874dde · e874dde
1 parent a5c0713
commit e874dde
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -225,9 +225,9 @@ func (c *MonitorController) handleErr(err error, key interface{}) {
 }
 
 func (c *MonitorController) onResourceAdded(obj interface{}) {
-	c.queue.Add(ResourceUpdatedAction{
+	c.queue.AddAfter(ResourceUpdatedAction{
 		resource: obj,
-	})
+	}, c.config.CreationDelay)
 }
 
 func (c *MonitorController) onResourceUpdated(old interface{}, new interface{}) {