Skip to content

Commit be212f9

Browse files
committed
feat: integrate apply params and results to workspacebindings in pipeline run
1 parent c351495 commit be212f9

File tree

2 files changed

+438
-0
lines changed

2 files changed

+438
-0
lines changed

pkg/reconciler/pipelinerun/pipelinerun.go

+3
Original file line numberDiff line numberDiff line change
@@ -531,6 +531,7 @@ func (c *Reconciler) reconcile(ctx context.Context, pr *v1.PipelineRun, getPipel
531531
return controller.NewPermanentError(err)
532532
}
533533

534+
resources.ApplyParametersToWorkspaceBindings(ctx, pipelineSpec, pr)
534535
// Make a deep copy of the Pipeline and its Tasks before value substution.
535536
// This is used to find referenced pipeline-level params at each PipelineTask when validate param enum subset requirement
536537
originalPipeline := pipelineSpec.DeepCopy()
@@ -844,6 +845,8 @@ func (c *Reconciler) runNextSchedulableTask(ctx context.Context, pr *v1.Pipeline
844845
c.setFinallyStartedTimeIfNeeded(pr, pipelineRunFacts)
845846
}
846847

848+
resources.ApplyResultsToWorkspaceBindings(pipelineRunFacts.State.GetTaskRunsResults(), pr)
849+
847850
for _, rpt := range nextRpts {
848851
if rpt.IsFinalTask(pipelineRunFacts) {
849852
c.setFinallyStartedTimeIfNeeded(pr, pipelineRunFacts)

0 commit comments

Comments
 (0)