func()

in job_definition.go [94:108]

• 13 lines of code
• 4 McCabe index (conditional complexity)

func (jd *JobDefinition[T]) addStep(step StepDefinitionMeta, precedingSteps ...StepDefinitionMeta) error {
	jd.steps[step.GetName()] = step
	jd.stepsDag.AddNode(step)
	for _, precedingStep := range precedingSteps {
		if err := jd.stepsDag.Connect(precedingStep, step); err != nil {
			if errors.Is(err, graph.ErrConnectNotExistingNode) {
				return ErrRefStepNotInJob.WithMessage(fmt.Sprintf("referenced step %s not found", precedingStep.GetName()))
			}

			return err
		}
	}

	return nil
}