workflow

Documentation

Index

• func DAGWorkflow(ctx wf.Context, input payload.DAGWorkflowInput) (*payload.FunctionDAGWorkflowOutput, error)
• func ExecuteFunctionWorkflow(ctx wf.Context, input payload.FunctionExecutionInput) (*payload.FunctionExecutionOutput, error)
• func FunctionPipelineWorkflow(ctx wf.Context, ...) (*generic.PipelineOutput[payload.FunctionExecutionOutput], error)
• func InstrumentedDAGWorkflow(ctx wf.Context, input payload.DAGWorkflowInput) (*payload.FunctionDAGWorkflowOutput, error)
• func LoopWorkflow(ctx wf.Context, ...) (*generic.LoopOutput[payload.FunctionExecutionOutput], error)
• func ParallelFunctionsWorkflow(ctx wf.Context, ...) (*generic.ParallelOutput[payload.FunctionExecutionOutput], error)
• func ParameterizedLoopWorkflow(ctx wf.Context, ...) (*generic.LoopOutput[payload.FunctionExecutionOutput], error)

Functions

func DAGWorkflow

func DAGWorkflow(ctx wf.Context, input payload.DAGWorkflowInput) (*payload.FunctionDAGWorkflowOutput, error)

DAGWorkflow executes functions in a DAG (Directed Acyclic Graph) pattern. Execution order is determined by the dependency graph, with support for input mappings (passing outputs between nodes) and data mappings (passing byte data between nodes).

func ExecuteFunctionWorkflow

func ExecuteFunctionWorkflow(ctx wf.Context, input payload.FunctionExecutionInput) (*payload.FunctionExecutionOutput, error)

ExecuteFunctionWorkflow runs a single function and returns results.

func FunctionPipelineWorkflow

func FunctionPipelineWorkflow(
	ctx wf.Context,
	input generic.PipelineInput[*payload.FunctionExecutionInput, payload.FunctionExecutionOutput],
) (*generic.PipelineOutput[payload.FunctionExecutionOutput], error)

FunctionPipelineWorkflow executes functions sequentially. Accepts the generic PipelineInput directly.

func InstrumentedDAGWorkflow

func InstrumentedDAGWorkflow(ctx wf.Context, input payload.DAGWorkflowInput) (*payload.FunctionDAGWorkflowOutput, error)

InstrumentedDAGWorkflow wraps DAGWorkflow with structured logging at boundaries.

func LoopWorkflow

func LoopWorkflow(
	ctx wf.Context,
	input generic.LoopInput[*payload.FunctionExecutionInput, payload.FunctionExecutionOutput],
) (*generic.LoopOutput[payload.FunctionExecutionOutput], error)

LoopWorkflow executes functions in a loop over items. Accepts the generic LoopInput directly.

func ParallelFunctionsWorkflow

func ParallelFunctionsWorkflow(
	ctx wf.Context,
	input generic.ParallelInput[*payload.FunctionExecutionInput, payload.FunctionExecutionOutput],
) (*generic.ParallelOutput[payload.FunctionExecutionOutput], error)

ParallelFunctionsWorkflow executes multiple functions in parallel. Accepts the generic ParallelInput directly.

func ParameterizedLoopWorkflow

func ParameterizedLoopWorkflow(
	ctx wf.Context,
	input generic.ParameterizedLoopInput[*payload.FunctionExecutionInput, payload.FunctionExecutionOutput],
) (*generic.LoopOutput[payload.FunctionExecutionOutput], error)

ParameterizedLoopWorkflow executes functions with parameterized loops. Accepts the generic ParameterizedLoopInput directly.