adaptive-workflow

Prompt file imported from AaradhyaDT/Fleet-Orchestrator (.github/prompts/adaptive-workflow.prompt.md). Fill in {{arg2}}, {{arg1}} before use. Copyright stays with the author.

Adaptive Workflow Orchestrator (adaptive-workflow)

Universal meta-orchestrator for Aaradhya's ecosystem (28 modules, 32 branches). Enforces context firebreak (INV-CTX-FIREBREAK), solves CPM DAGs mathematically, marshals 27-worker Fleet pool & Colab GPU accelerators, routes 8 domain archetypes with ai-engineering-fellowship, and drives Fleet Master Brain (3B/7B) with Agent-Reflex.

1. Command Hierarchy & Context Firebreak

flowchart TD
    User["User Goals"] --> Lead["Lead Agent (Main Chat)\n- Context <5k tokens\n- Fast paths (<20 ms)\n- Port 1234 router"]
    Lead -->|"Subagent"| Cmdr["Fleet Commander\nChild context"]
    Cmdr -->|"Enqueue"| Q["Fleet Queue"]
    Q --> W["27x Workers (.worktrees/<task_id>)"]
    W --> Exec["Step Run"]
    Exec --> Err{"Exit == 0?"}
    Err -- No --> Reflex["Agent-Reflex (1234)\nAuto fix (<50 ms)"]
    Reflex --> Exec
    Err -- Yes --> CP["Checkpoints"]
    CP --> Cmdr -->|"Manifest <300w"| Lead --> Delivery["Verified Delivery (sync.bat)"]

Hierarchy Responsibilities:

1. Lead Agent: Triage via adaptive_engine.py. Tier 0 fast paths ($0). Solves CPM ($TS=0$). Ephemeral Commander (invoke_subagent), context $<5\text{k}$ tokens (INV-CTX-FIREBREAK).
2. Domain Commanders: Writes task JSONs to orchestrator-state/tasks/. Absorbs logs/retries. Returns <300w manifest to Lead.
3. Headless Workers & Cloud: 27 accounts in .worktrees/<task_id> + ColabCloudAdapter (zero local .ipynb).
4. Agent-Reflex: Intercepts tool errors at port 1234 ([Error] -> [Fix]) for sub-second recovery (INV-AGENT-REFLEX).

Protocols: references/fleet-command-architecture.md.

2. Multi-Tier Execution Hierarchy & Fast Paths

Fast paths: references/deterministic-zero-ai-protocol.md. Models: references/fleet-master-brain-models.md. Reflex: references/agent-reflex-and-tool-speculator.md.

3. Mathematical CPM Concurrency

Dates, critical paths, and slacks are solved in sim/adaptive_orchestrator.py with zero prompt arithmetic:

python tools/adaptive_engine.py cpm --dag-json path/to/dag.json

• Dates: $ES_j = \max_{i \in Pred(j)} EF_i$, $EF_j = ES_j + D_j$; $LF_i = \min_{j \in Succ(i)} LS_j$, $LS_i = LF_i - D_i$.
• Slacks: $TS_i = LF_i - EF_i$; $FS_i = \min_{j \in Succ(i)} ES_j - EF_i$.
• Critical Path: Tasks with $TS = 0$ (sequential). Parallel branches with $TS > 0$ dispatch concurrently.

Mechanics: references/cpm-concurrency-dispatch.md.

4. 2D Orthogonal Execution Matrix

Decouples Workload Volume ($V0 \le 2$, $V1 = 3\text{–}15$, $V2 > 15$ files) from Blast Criticality ($R0 \le 0.10$, $R1 = 0.10\text{–}0.35$, $R2 > 0.35$):

$$C = \min\left(1.0, \max\left(0.0, \frac{2|D| + |T_{\text{ind}}|}{2(N - 1)}\right)\right), \quad N = 28$$

python tools/adaptive_engine.py triage "refactor router" --files sim/routing_engine.py

Matrix reference: references/orthogonal-execution-matrix.md.

5. Memory Guard & Flight Envelope

Enforces Antigravity IDE stability and Banker's safety:

• Reserve Floor: {{arg2}},048\text{ MB}$ free RAM permanently reserved for Antigravity IDE.
• Worker Concurrency: $\lfloor (\text{Free RAM} - 2048) / 256 \rfloor$. $[2048, 2303]\text{MB} \implies 0$; $[2304, 4096]\text{MB} \implies 1\text{–}8$.
• Rate Governor: Targets $L_{\text{target}} = 1200\text{ms}$. On $\ge 2$ 429s in 60s, $M$ halved to $\max(0.25, M/2)$ (120s window). Success ramps $M$ by $+0.1$ to {{arg1}}.0$.

Envelope reference: references/dynamic-flight-envelope.md.

6. Transactional Recovery & Fencing

• Rolling Snapshots: adaptive_engine.py snapshot --tag <name> (rollback: rollback --tag <name>).
• Pre-Existing File Guard (INV-PRE-EXIST-GUARD): Backs up existing files to <git_common_dir>/projection_backups/<task_id>/, restoring on teardown.
• Fencing Tokens (INV-FENCE-TOKEN): Monotonic tokens reject split-brain writes from stale workers.

Recovery reference: references/transactional-recovery.md.

7. Supporting References & Verification

• references/skill-matrix.md: 8-archetype routing & fellowship matrix.
• references/installed-work-tools-catalog.md: Workstation software catalog.
• references/agent-reflex-and-tool-speculator.md: Agent-Reflex & Tool-Speculator.
• references/fleet-master-brain-models.md: Dual-model (3B/7B), A100 training, Drive retrieval.
• references/historical-provenance.md: Baseline lock ($v3.5.0 \to v3.10.0$) & 15 invariants.
• references/verification-gates.md: Verification sequence (INV-AUDIT-ORDER).
• references/worker-availability-ledger.md: Worker exhaustion & state mapping table.
• references/quota-velocity-acceleration.md: Credit trading for velocity.
• references/antigravity-chat-context-injection.md: Customization projection to workers.
• references/ecosystem-repos.md: Catalog of 28 registered tool modules.
• examples/routing-scenarios.md: Walkthroughs across domain archetypes.