diff --git a/workflow/cron/operator.go b/workflow/cron/operator.go index 03889cc225a6..f76d45ed8171 100644 --- a/workflow/cron/operator.go +++ b/workflow/cron/operator.go @@ -90,6 +90,10 @@ func (woc *cronWfOperationCtx) run(ctx context.Context, scheduledRuntime time.Ti runWf, err := util.SubmitWorkflow(ctx, woc.wfClient, woc.wfClientset, woc.cronWf.Namespace, wf, &v1alpha1.SubmitOpts{}) if err != nil { + // If the workflow already exists (i.e. this is a duplicate submission), do not report an error + if errors.IsAlreadyExists(err) { + return + } woc.reportCronWorkflowError(v1alpha1.ConditionTypeSubmissionError, fmt.Sprintf("Failed to submit Workflow: %s", err)) return }