Skip to main content

Module scheduler

Module scheduler 

Source
Expand description

Dataflow scheduler.

Walks the pipeline DAG in topological order, spawning a shared future per step. Each future awaits its predecessors, acquires a parallelism permit, and dispatches the step to its registered runner (Docker by default).

Functionsยง

run
Entry point: run a parsed pipeline locally end-to-end. Returns the overall exit code (0 = success, crate::error::EXIT_BUILD_FAILED when any step exited non-zero).