diff --git a/internal/controller/valkey_controller.go b/internal/controller/valkey_controller.go index 5113944..48668f8 100644 --- a/internal/controller/valkey_controller.go +++ b/internal/controller/valkey_controller.go @@ -787,7 +787,9 @@ fi return err } r.Recorder.Event(valkey, "Normal", "Updated", fmt.Sprintf("StatefulSet %s/%s is updated (replicas)", valkey.Namespace, valkey.Name)) - r.balanceNodes(ctx, valkey, oldnodes, *sts.Spec.Replicas) + if err := r.balanceNodes(ctx, valkey, oldnodes, *sts.Spec.Replicas); err != nil { + return err + } } return nil