in step_builder.go [296:309]
func getDependsOnStepInstances(stepD StepDefinitionMeta, ji JobInstanceMeta) ([]StepInstanceMeta, []asynctask.Waitable, error) {
var precedingInstances []StepInstanceMeta
var precedingTasks []asynctask.Waitable
for _, depStepName := range stepD.DependsOn() {
if depStep, ok := ji.GetStepInstance(depStepName); ok {
precedingInstances = append(precedingInstances, depStep)
precedingTasks = append(precedingTasks, depStep.Waitable())
} else {
return nil, nil, ErrRuntimeStepNotFound.WithMessage(fmt.Sprintf(MsgRuntimeStepNotFound, depStepName))
}
}
return precedingInstances, precedingTasks, nil
}