diff --git a/pkg/operator/ceph/cluster/cleanup.go b/pkg/operator/ceph/cluster/cleanup.go index c0eaffedda78..41ed0ab5825c 100644 --- a/pkg/operator/ceph/cluster/cleanup.go +++ b/pkg/operator/ceph/cluster/cleanup.go @@ -198,7 +198,6 @@ func (c *ClusterController) waitForCephDaemonCleanUp(stopCleanupCh chan struct{} logger.Debugf("waiting for ceph daemons in cluster %q to be cleaned up. Retrying in %q", cluster.Namespace, retryInterval.String()) - break case <-stopCleanupCh: return errors.New("cancelling the host cleanup job") }