diff --git a/internal/controller/cluster/reconciler.go b/internal/controller/cluster/reconciler.go index 2d210720..9f457506 100644 --- a/internal/controller/cluster/reconciler.go +++ b/internal/controller/cluster/reconciler.go @@ -231,6 +231,16 @@ func (r *SingleClusterReconciler) Reconcile() (result ctrl.Result, recErr error) return reconcile.Result{}, recErr } + if r.IsReclusterNeeded() { + if err = deployment.InfoRecluster( + r.Log, + r.getClientPolicy(), allHostConns, + ); err != nil { + r.Log.Error(err, "Failed to do recluster") + return reconcile.Result{}, err + } + } + if asdbv1.IsClusterSCEnabled(r.aeroCluster) { if !r.IsStatusEmpty() { if res := r.waitForClusterStability(policy, allHostConns); !res.IsSuccess { @@ -249,16 +259,6 @@ func (r *SingleClusterReconciler) Reconcile() (result ctrl.Result, recErr error) } } - if r.IsReclusterNeeded() { - if err = deployment.InfoRecluster( - r.Log, - r.getClientPolicy(), allHostConns, - ); err != nil { - r.Log.Error(err, "Failed to do recluster") - return reconcile.Result{}, err - } - } - // Update the AerospikeCluster status. if err = r.updateStatus(); err != nil { r.Log.Error(err, "Failed to update AerospikeCluster status")