Function SimpleFunction

pkg/workflow/step.go:249–266

===== Helper Functions =====

(name string, fn func(input any) (any, error))

// ===== Helper Functions =====

func SimpleFunction(name string, fn func(input any) (any, error)) *FunctionStep {
	return NewFunctionStep(name, func(ctx context.Context, stepInput *StepInput) (*StepOutput, error) {
		input := stepInput.Input
		if input == nil && stepInput.PreviousStepContent != nil {
			input = stepInput.PreviousStepContent
		}

		output, err := fn(input)
		if err != nil {
			return nil, err
		}

		return &StepOutput{
			Content:  output,
			Metadata: make(map[string]any),
		}, nil
	})
}

func TransformFunction(name string, transform func(input any) any) *FunctionStep {
	return SimpleFunction(name, func(input any) (any, error) {