fix: retry create workflow on transient error

Signed-off-by: Tianchu Zhao <[email protected]>
atlanhq · Dec 5, 2024 · 0919980 · 0919980
1 parent b966acc
commit 0919980
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/workflow/util/util.go b/workflow/util/util.go
@@ -193,7 +193,13 @@ func SubmitWorkflow(ctx context.Context, wfIf v1alpha1.WorkflowInterface, wfClie
 		}
 		return wf, err
 	} else {
-		return wfIf.Create(ctx, wf, metav1.CreateOptions{})
+		var runWf *wfv1.Workflow
+		err = waitutil.Backoff(retry.DefaultRetry, func() (bool, error) {
+			var err error
+			runWf, err = wfIf.Create(ctx, wf, metav1.CreateOptions{})
+			return !errorsutil.IsTransientErr(err), err
+		})
+		return runWf, err
 	}
 }