diff --git a/pkg/controller/monitoring.go b/pkg/controller/monitoring.go index e89743282c7..986db140a53 100644 --- a/pkg/controller/monitoring.go +++ b/pkg/controller/monitoring.go @@ -289,7 +289,7 @@ func (c *Controller) syncHealthCheckHandler(key string) (Result, error) { // Add tenant to the health check queue again until is green again if tenant != nil && tenant.Status.HealthStatus != miniov2.HealthStatusGreen { - c.healthCheckQueue.Add(key) + c.healthCheckQueue.AddAfter(key, 1*time.Second) } return WrapResult(Result{}, nil) diff --git a/pkg/controller/pods.go b/pkg/controller/pods.go index fdf92d08447..9eeeef4b578 100644 --- a/pkg/controller/pods.go +++ b/pkg/controller/pods.go @@ -18,6 +18,7 @@ package controller import ( "fmt" + "time" miniov2 "github.com/minio/operator/pkg/apis/minio.min.io/v2" "github.com/minio/operator/pkg/utils" @@ -40,5 +41,5 @@ func (c *Controller) handlePodChange(obj interface{}) { } key := fmt.Sprintf("%s/%s", object.GetNamespace(), instanceName) - c.healthCheckQueue.Add(key) + c.healthCheckQueue.AddAfter(key, 1*time.Second) }