diff --git a/operator/redisfailover/handler.go b/operator/redisfailover/handler.go index 915cb5272..71cd3ecab 100644 --- a/operator/redisfailover/handler.go +++ b/operator/redisfailover/handler.go @@ -58,7 +58,15 @@ func (r *RedisFailoverHandler) Handle(_ context.Context, obj runtime.Object) err if !ok { return fmt.Errorf("can't handle the received object: not a redisfailover") } - + + if rf.Annotations != nil { + skipReconcile, ok := rf.Annotations["skip-reconcile"] + if ok && skipReconcile == "true" { + r.logger.Infoln("skip-reconcile set to true. Skipping reconcile for", rf.Name) + return nil + } + } + if err := rf.Validate(); err != nil { r.mClient.SetClusterError(rf.Namespace, rf.Name) return err