small fix

Author: pooknull

pkg/controller/perconaservermongodbrestore/physical.go

@@ -288,31 +288,16 @@ func (r *ReconcilePerconaServerMongoDBRestore) reconcilePhysicalRestore(
 
 	finished, err := r.finishPhysicalRestore(ctx, cluster)
 	if err != nil {
-		return status, err // TODO: shouldn't return error
+		log.Error(err, "Failed to recover the cluster after the restore")
+		status.State = psmdbv1.RestoreStateReady
+		return status, nil
 	}
 	if !finished {
 		return status, nil
 	}
 
 	status.State = psmdbv1.RestoreStateReady
 
-	err = retry.RetryOnConflict(retry.DefaultBackoff, func() error {
-		c := new(psmdbv1.PerconaServerMongoDB)
-		if err := r.client.Get(ctx, client.ObjectKeyFromObject(cluster), c); err != nil {
-			return err
-		}
-
-		if c.Annotations == nil {
-			c.Annotations = make(map[string]string)
-		}
-		c.Annotations[psmdbv1.AnnotationResyncPBM] = "true"
-
-		return r.client.Update(ctx, c)
-	})
-	if err != nil {
-		return status, errors.Wrapf(err, "annotate psmdb/%s for PBM resync", cluster.Name)
-	}
-
 	return status, nil
 }
 
@@ -415,6 +400,22 @@ func (r *ReconcilePerconaServerMongoDBRestore) finishPhysicalRestore(ctx context
 		return false, nil
 	}
 
+	if err = retry.RetryOnConflict(retry.DefaultBackoff, func() error {
+		c := new(psmdbv1.PerconaServerMongoDB)
+		if err := r.client.Get(ctx, client.ObjectKeyFromObject(cluster), c); err != nil {
+			return err
+		}
+
+		if c.Annotations == nil {
+			c.Annotations = make(map[string]string)
+		}
+		c.Annotations[psmdbv1.AnnotationResyncPBM] = "true"
+
+		return r.client.Update(ctx, c)
+	}); err != nil {
+		return false, errors.Wrapf(err, "annotate psmdb/%s for PBM resync", cluster.Name)
+	}
+
 	if err := r.updateMongodSts(ctx, cluster, func(sts *appsv1.StatefulSet) error {
 		if sts.Annotations[psmdbv1.AnnotationRestoreInProgress] == "true" {
 			delete(sts.Annotations, psmdbv1.AnnotationRestoreInProgress)