Skip to main content

Module parallel

Module parallel 

Source
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§

IntegrationConfig
Configuration for the integration loop.
RemediationHandoff
Structured handoff packet for blocked remediation attempts.

Enums§

IntegrationOutcome
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.