diff --git a/pkg/operator/ceph/disruption/machinedisruption/reconcile.go b/pkg/operator/ceph/disruption/machinedisruption/reconcile.go index 8f1aceec9..8ac983e72 100644 --- a/pkg/operator/ceph/disruption/machinedisruption/reconcile.go +++ b/pkg/operator/ceph/disruption/machinedisruption/reconcile.go @@ -129,7 +129,7 @@ func (r *MachineDisruptionReconciler) reconcile(request reconcile.Request) (reco mdb.Spec.MaxUnavailable = &maxUnavailable } // Check if the cluster is clean or not - _, isClean, err := cephClient.IsClusterClean(r.context.ClusterdContext, request.Name) + _, isClean, err := cephClient.IsClusterClean(r.context.ClusterdContext, request.Namespace) if err != nil { maxUnavailable := int32(0) mdb.Spec.MaxUnavailable = &maxUnavailable