From 2e91ff16620f1aba52602f67f22b91cd67539db5 Mon Sep 17 00:00:00 2001 From: changzhen Date: Tue, 28 Jun 2022 16:27:50 +0800 Subject: [PATCH] return err when create resource failed Signed-off-by: changzhen --- pkg/util/objectwatcher/objectwatcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/util/objectwatcher/objectwatcher.go b/pkg/util/objectwatcher/objectwatcher.go index cd657be48..fbe66a9df 100644 --- a/pkg/util/objectwatcher/objectwatcher.go +++ b/pkg/util/objectwatcher/objectwatcher.go @@ -85,7 +85,7 @@ func (o *objectWatcherImpl) Create(clusterName string, desireObj *unstructured.U clusterObj, err := dynamicClusterClient.DynamicClientSet.Resource(gvr).Namespace(desireObj.GetNamespace()).Create(context.TODO(), desireObj, metav1.CreateOptions{}) if err != nil { klog.Errorf("Failed to create resource(kind=%s, %s/%s) in cluster %s, err is %v ", desireObj.GetKind(), desireObj.GetNamespace(), desireObj.GetName(), clusterName, err) - return nil + return err } klog.Infof("Created resource(kind=%s, %s/%s) on cluster: %s", desireObj.GetKind(), desireObj.GetNamespace(), desireObj.GetName(), clusterName)