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_FAILEDwhen any step exited non-zero).