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 |