diff --git a/server/pipeline/create.go b/server/pipeline/create.go index 64bd6f623..7d711af34 100644 --- a/server/pipeline/create.go +++ b/server/pipeline/create.go @@ -87,10 +87,6 @@ func Create(ctx context.Context, _store store.Store, repo *model.Repo, pipeline return nil, ErrFiltered } - if err := updatePipelinePending(ctx, _store, pipeline, repo, repoUser); err != nil { - return nil, err - } - pipeline = setPipelineStepsOnPipeline(pipeline, pipelineItems) // persist the pipeline config for historical correctness, restarts, etc @@ -116,6 +112,10 @@ func Create(ctx context.Context, _store store.Store, repo *model.Repo, pipeline return pipeline, nil } + if err := updatePipelinePending(ctx, _store, pipeline, repo, repoUser); err != nil { + return nil, err + } + pipeline, err = start(ctx, _store, pipeline, repoUser, repo, pipelineItems) if err != nil { msg := fmt.Sprintf("failed to start pipeline for %s", repo.FullName)