Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
Signed-off-by: shuangkun <tsk2013uestc@163.com>
  • Loading branch information
shuangkun committed Dec 19, 2023
1 parent bc64cdb commit 3c9921c
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions workflow/controller/steps.go
Original file line number Diff line number Diff line change
Expand Up @@ -415,7 +415,7 @@ func (woc *wfOperationCtx) resolveReferences(stepGroup []wfv1.WorkflowStep, scop
return nil, err
}

resolveStepReferences := func(i int, step *wfv1.WorkflowStep, newStepGroup []wfv1.WorkflowStep) error {
resolveStepReferences := func(i int, step wfv1.WorkflowStep, newStepGroup []wfv1.WorkflowStep) error {
// Step 1: replace all parameter scope references in the step
stepBytes, err := json.Marshal(step)
if err != nil {
Expand Down Expand Up @@ -477,14 +477,14 @@ func (woc *wfOperationCtx) resolveReferences(stepGroup []wfv1.WorkflowStep, scop
for i, step := range stepGroup {
parallelStepNum <- step.Name
wg.Add(1)
go func(i int, step *wfv1.WorkflowStep) {
go func(i int, step wfv1.WorkflowStep) {
defer wg.Done()
if err := resolveStepReferences(i, step, newStepGroup); err != nil {
woc.log.WithFields(log.Fields{"stepName": step.Name}).WithError(err).Error(err.Error())
resolveReferenceError = err
}
<-parallelStepNum
}(i, &step)
}(i, step)
}
wg.Wait()
if resolveReferenceError != nil {
Expand Down

0 comments on commit 3c9921c

Please sign in to comment.