Expand description
Parallel run loop supervisor and worker orchestration for direct-push mode.
Responsibilities:
- Coordinate parallel task execution across multiple workers.
- Manage settings resolution and preflight validation.
- Track worker capacity and task pruning.
- Handle direct-push integration from workers.
Not handled here:
- Main orchestration loop (see
orchestration.rs). - State initialization (see
state_init.rs). - Worker lifecycle (see
worker.rs). - Integration loop logic (see
integration.rs).
Invariants/assumptions:
- Queue order is authoritative for task selection.
- Workers run in isolated per-task workspaces on the target base branch.
- Workers push directly to the target branch (no PRs).
- One active worker per task ID (enforced by upsert_worker).
Re-exports§
pub use state::WorkerLifecycle;pub use state::WorkerRecord;
Modules§
- state
- Parallel run state persistence for crash recovery.
Structs§
- Integration
Config - Configuration for the integration loop.
- Remediation
Handoff - Structured handoff packet for blocked remediation attempts.
Enums§
- Integration
Outcome - Outcome of the integration loop.
Constants§
- BLOCKED_
PUSH_ MARKER_ FILE - Marker file name for blocked push outcomes from integration loop.
- CI_
FAILURE_ MARKER_ FALLBACK_ FILE - Fallback marker file used only when primary marker path is unavailable.
- CI_
FAILURE_ MARKER_ FILE - Marker file name for CI gate failure diagnostics. Written to workspace when CI fails so coordinator/status tooling can inspect failures.
Functions§
- default_
push_ backoff_ ms - Default push backoff intervals in milliseconds.