Function NewParallelStep

pkg/workflow/step.go:497–510

(name string, steps ...Step)

}

func NewParallelStep(name string, steps ...Step) *ParallelStep {
	return &ParallelStep{
		id:    uuid.New().String(),
		name:  name,
		steps: steps,
		config: &StepConfig{
			Name:        name,
			Type:        StepTypeParallel,
			MaxRetries:  1,
			Timeout:     10 * time.Minute,
			SkipOnError: false,
		},
	}
}

func (s *ParallelStep) ID() string          { return s.id }
func (s *ParallelStep) Name() string        { return s.name }