orchestrata_ultimate.factory.scheduler
Reference › orchestrata_ultimate › factory › scheduler › init
Package marker for the DAG scheduler, level-parallel worktrees and integration re-gate (SPEC-033 section 9, row B9). It defines no code of its own; see the package page.
At a glance
| Source | src/orchestrata_ultimate/factory/scheduler/__init__.py |
| Lines of code | 27 |
| Classes | 0 |
| Functions | 0 |
| Imports (internal) | none |
| Imported by | none |
| Tests that import it | none |
Class diagram
No classes; see Functions.
Dependency diagram
No internal imports and no importers.
API
No public API: the module defines no classes, functions or constants.
Source
"""DAG scheduler + level-parallel worktrees + integration re-gate (SPEC-033 §9, B9).
ADR-0004 ("facts keyed by `(worktree, commit)`; merge is fact promotion,
serialised") is the load-bearing design this package makes executable: a
build DAG's independent tasks run **concurrently** (one real `git worktree`
lease per task, one Neo4j fact-namespace per task), while **promotion stays
strictly serial** through a single :class:`~.queue.MergeQueue` drained
between DAG levels -- so level N+1 always dispatches against a trunk that
already contains level N's promotions (the "integration re-gate").
Modules
-------
dag ``TaskSpec``/``BuildContext``/``BuildResult`` (the injected-build
seam) and ``build_levels`` -- Kahn topological leveling with
``CyclicDependency`` on a cycle.
worktrees ``WorktreeLease`` + ``lease``/``release`` -- real
``git worktree add --detach``/``remove`` under
``<repo_root>/.factory-worktrees/<task_id>/``.
queue ``MergeQueue``/``MergeEntry``/``RegateVerdict``/``MergeOutcome`` --
the strictly-serial integration re-gate + promotion drain (B21,
ADR-0033: the queue itself is the distinct promoting identity).
scheduler ``run_pipeline``/``PipelineReport``/``TaskReport`` -- wires the
above together: level-parallel dispatch through the B21 gates,
serial drain between levels, lease release + GC.
"""
from __future__ import annotations