orchestrata_ultimate.factory.scheduler

Reference › orchestrata_ultimate › factory › scheduler

DAG scheduler + level-parallel worktrees + integration re-gate (SPEC-033 §9, B9).

The scheduler package builds tasks in dependency order with parallelism inside each level (SPEC-033 section 9, row B9). dag defines TaskSpec and levels the task graph. worktrees leases a detached git worktree per task. queue holds the MergeQueue, which runs the integration re-gate and promotes strictly one at a time. scheduler holds run_pipeline, which ties these together with the dispatch gates and the promotion store. Control flows level by level: gate, lease, build and enqueue for each task in parallel, then a serial drain and a watermark wait before the next level, and finally release of leases and garbage collection. The CLI entry point is scripts.factory_pipeline. Start with scheduler.

5 modules, 686 lines of code.

Modules

Module Summary LOC
__init__ DAG scheduler + level-parallel worktrees + integration re-gate (SPEC-033 §9, B9). 27
dag TaskSpec + Kahn topological leveling for the build DAG (SPEC-033 §9, B9). 108
queue MergeQueue -- the strictly-serial integration re-gate + promotion drain. 156
scheduler run_pipeline -- level-parallel DAG build + serial integration re-gate (SPEC-033 §9, B9). 292
worktrees Real git-worktree leases for level-parallel building (SPEC-033 §9, B9). 103

Dependency diagram

Package dependency diagram orchestrata_ultimate.factory.scheduler