Module execution 

Shared workflow execution logic.

Provides generic execution functions that can be used by different runners (in-process, Python bindings, etc.) by supplying task execution callbacks.

Enums

ResumeOutcome

Outcome of prepare_resume.

Functions

execute_continuation_async

Execute a workflow continuation asynchronously with parallel branch execution.

execute_continuation_sync

Execute a workflow continuation synchronously.

execute_continuation_with_checkpointing

Execute a workflow continuation with checkpointing after each task.

finalize_execution

Finalize a workflow execution, converting the result to a WorkflowStatus.

get_resume_input

Get the input for resuming execution from a snapshot.

prepare_resume

Prepare to resume a workflow from a saved snapshot.

prepare_run

Prepare a fresh workflow run: create initial snapshot and save it.

serialize_branch_results

Serialize named branch results into a format that can be passed to the join task.