Module executor 

Workflow execution engine.

Parallel Fan-out / Fan-in

WorkflowExecutor::execute automatically discovers independent groups of tasks — tasks whose dependencies are all satisfied at the same time — and launches them concurrently. When all tasks in a fan-out group complete the join point (fan-in) tasks are unblocked. This happens naturally through the dependency-tracking loop; no explicit graph analysis is required.

Pause / Resume

Call WorkflowExecutor::pause to signal the executor to stop launching new tasks after the current wave completes. The checkpoint is serialised to a JSON string containing the completed task IDs and execution context variables. Pass that string to WorkflowExecutor::resume_from_checkpoint to reconstruct the state and continue.

Structs

DefaultTaskExecutor

Default task executor implementation.

ExecutionCheckpoint

Serializable checkpoint for pause/resume of workflow execution.

ExecutionContext

Execution context shared across task executions.

ExecutionResult

Workflow execution result.

WorkflowExecutor

Workflow executor.

Enums

WorkflowControl

High-level control signal for a running WorkflowExecutor.

Traits

TaskExecutor

Task executor trait.

Functions

parse_condition

Parse and evaluate a single condition expression against the execution context.