Handle issue where DB secret already exists by requeueing and restart…

…ing the flow (#157)
otterize · Sep 15, 2024 · 185a6e5 · 185a6e5
1 parent 78fe3f2
commit 185a6e5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/operator/controllers/poduserpassword/db_credentials_pod_reconciler.go b/src/operator/controllers/poduserpassword/db_credentials_pod_reconciler.go
@@ -185,6 +185,9 @@ func (e *Reconciler) ensurePodUserAndPasswordSecret(ctx context.Context, pod *v1
 		secret := buildUserAndPasswordCredentialsSecret(secretName, pod.Namespace, username, password)
 		log.WithField("secret", secretName).Debug("Creating new secret with user-password credentials")
 		if err := e.client.Create(ctx, secret); err != nil {
+			if apierrors.IsAlreadyExists(err) {
+				return ctrl.Result{Requeue: true}, false, "", nil
+			}
 			return ctrl.Result{}, false, "", errors.Wrap(err)
 		}
 		return ctrl.Result{}, true, password, nil