requeue if not ready

Signed-off-by: Jordan Rodgers <[email protected]>
OT-CONTAINER-KIT · Aug 2, 2024 · 62b750c · 62b750c
1 parent a9f97cb
commit 62b750c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/controllers/rediscluster_controller.go b/controllers/rediscluster_controller.go
@@ -148,7 +148,7 @@ func (r *RedisClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request
 	}
 
 	if !(r.IsStatefulSetReady(ctx, r.K8sClient, instance, instance.Name+"-leader", instance.Namespace) && r.IsStatefulSetReady(ctx, r.K8sClient, instance, instance.Name+"-follower", instance.Namespace)) {
-		return intctrlutil.Reconciled()
+		return intctrlutil.RequeueAfter(reqLogger, time.Second*10, "Redis cluster is not ready")
 	}
 
 	// Mark the cluster status as bootstrapping if all the leader and follower nodes are ready

diff --git a/controllers/redisreplication_controller.go b/controllers/redisreplication_controller.go
@@ -58,7 +58,7 @@ func (r *RedisReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Req
 		return intctrlutil.RequeueWithError(err, reqLogger, "")
 	}
 	if !r.IsStatefulSetReady(ctx, r.K8sClient, instance, instance.Name, instance.Namespace) {
-		return intctrlutil.Reconciled()
+		return intctrlutil.RequeueAfter(reqLogger, time.Second*10, "")
 	}
 
 	var realMaster string