From baf11b4e972ed6eca13fe158e995fd06a491a329 Mon Sep 17 00:00:00 2001
From: MegaByte875 <kevin.qiao@vesoft.com>
Date: Mon, 26 Feb 2024 19:39:27 +0800
Subject: [PATCH] remove not found error (#453)

---
 .../nebularestore/nebula_restore_control.go   | 48 +++++++++----------
 .../nebularestore/nebula_restore_manager.go   |  1 +
 2 files changed, 24 insertions(+), 25 deletions(-)

diff --git a/pkg/controller/nebularestore/nebula_restore_control.go b/pkg/controller/nebularestore/nebula_restore_control.go
index 7a522a43..4bdb7faa 100644
--- a/pkg/controller/nebularestore/nebula_restore_control.go
+++ b/pkg/controller/nebularestore/nebula_restore_control.go
@@ -18,7 +18,6 @@ package nebularestore
 
 import (
 	corev1 "k8s.io/api/core/v1"
-	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/klog/v2"
 
 	"github.com/vesoft-inc/nebula-operator/apis/apps/v1alpha1"
@@ -99,34 +98,33 @@ func (c *defaultRestoreControl) UpdateNebulaRestore(nr *v1alpha1.NebulaRestore)
 		}
 	}
 
-	err := c.restoreManager.Sync(nr)
-	if err != nil && !utilerrors.IsReconcileError(err) {
-		if apierrors.IsNotFound(err) {
-			return nil
-		}
-		if err := c.clientSet.NebulaRestore().UpdateNebulaRestoreStatus(nr, &v1alpha1.RestoreCondition{
-			Type:    v1alpha1.RestoreFailed,
-			Status:  corev1.ConditionTrue,
-			Reason:  "ExecuteFailed",
-			Message: err.Error(),
-		}, &kube.RestoreUpdateStatus{
-			ConditionType: v1alpha1.RestoreFailed,
-		}); err != nil {
-			klog.Errorf("Fail to update the condition of NebulaRestore [%s/%s], %v", ns, name, err)
-		}
-		updated, err := c.clientSet.NebulaRestore().GetNebulaRestore(ns, nr.Name)
-		if err != nil {
-			klog.Errorf("Fail to get NebulaRestore [%s/%s], %v", ns, name, err)
-		}
-		if nr.Spec.AutoRemoveFailed {
-			if err := c.deleteRestoredCluster(ns, updated.Status.ClusterName); err != nil {
-				klog.Errorf("Fail to delete NebulaCluster %v", err)
+	if err := c.restoreManager.Sync(nr); err != nil {
+		if !utilerrors.IsReconcileError(err) {
+			if err := c.clientSet.NebulaRestore().UpdateNebulaRestoreStatus(nr, &v1alpha1.RestoreCondition{
+				Type:    v1alpha1.RestoreFailed,
+				Status:  corev1.ConditionTrue,
+				Reason:  "ExecuteFailed",
+				Message: err.Error(),
+			}, &kube.RestoreUpdateStatus{
+				ConditionType: v1alpha1.RestoreFailed,
+			}); err != nil {
+				klog.Errorf("Fail to update the condition of NebulaRestore [%s/%s], %v", ns, name, err)
 			}
+			updated, err := c.clientSet.NebulaRestore().GetNebulaRestore(ns, nr.Name)
+			if err != nil {
+				klog.Errorf("Fail to get NebulaRestore [%s/%s], %v", ns, name, err)
+			}
+			if nr.Spec.AutoRemoveFailed {
+				if err := c.deleteRestoredCluster(ns, updated.Status.ClusterName); err != nil {
+					klog.Errorf("Fail to delete NebulaCluster %v", err)
+				}
+			}
+			return nil
 		}
-		return nil
+		return err
 	}
 
-	return err
+	return nil
 }
 
 func (c *defaultRestoreControl) deleteRestoredCluster(namespace, ncName string) error {
diff --git a/pkg/controller/nebularestore/nebula_restore_manager.go b/pkg/controller/nebularestore/nebula_restore_manager.go
index e12cffc8..e5f5e1ed 100644
--- a/pkg/controller/nebularestore/nebula_restore_manager.go
+++ b/pkg/controller/nebularestore/nebula_restore_manager.go
@@ -105,6 +105,7 @@ func (rm *restoreManager) syncRestoreProcess(nr *v1alpha1.NebulaRestore) error {
 	}
 	original, err := rm.clientSet.NebulaCluster().GetNebulaCluster(ns, originalName)
 	if err != nil {
+		klog.Errorf("backup cluster [%s/%s] not found", ns, originalName)
 		return err
 	}