added already exists error

kuidio · May 20, 2024 · 8366694 · 8366694
1 parent 61117f4
commit 8366694
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/pkg/reconcilers/resource/errors.go b/pkg/reconcilers/resource/errors.go
@@ -50,3 +50,9 @@ func IgnoreAny(err error, is ...ErrorIs) error {
 func IgnoreNotFound(err error) error {
 	return Ignore(errors.IsNotFound, err)
 }
+
+// IgnoreAlreadyExist returns the supplied error, or nil if the error indicates a
+// Kubernetes resource that  already exists.
+func IgnoreAlreadyExist(err error) error {
+	return Ignore(errors.IsAlreadyExists, err)
+}
diff --git a/pkg/resources/recources.go b/pkg/resources/recources.go
@@ -241,7 +241,10 @@ func (r *Resources) apply(ctx context.Context, o backend.GenericObject) error {
 		}
 		if err := r.Client.Create(ctx, o); err != nil {
 			log.Error("cannot create resource", "key", key.String(), "error", err.Error())
-			return err
+			if resource.IgnoreAlreadyExist(err) != nil {
+				return err
+			}
+			return nil
 		}
 		return nil
 	}