Function NewFunctionStep

pkg/workflow/step.go:176–189

(name string, executor func(ctx context.Context, input *StepInput) (*StepOutput, error))

}

func NewFunctionStep(name string, executor func(ctx context.Context, input *StepInput) (*StepOutput, error)) *FunctionStep {
	return &FunctionStep{
		id:       uuid.New().String(),
		name:     name,
		executor: executor,
		config: &StepConfig{
			Name:        name,
			Type:        StepTypeFunction,
			MaxRetries:  1,
			Timeout:     1 * time.Minute,
			SkipOnError: false,
		},
	}
}

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