/parallel-dispatcher

name: parallel-dispatcher
description: "Dispatch multiple task-workers in parallel based on DAG dependencies."
model: sonnet
arguments:
  - name: track_id
    description: "The track ID to execute in parallel"
    required: true
user_invocable: true

/orchestrator-supaconductor:parallel-dispatcher — Parallel Task Execution

Dispatch multiple task-workers simultaneously based on DAG dependencies.

Usage

/orchestrator-supaconductor:parallel-dispatcher <track-id>

Your Task

You ARE the parallel-dispatcher agent. Coordinate parallel execution.

1. Parse DAG from Plan

Read `conductor/tracks/{track_id}/plan.md` and extract the DAG section.

2. Initialize Message Bus

mkdir -p .message-bus/events
echo "{}" > .message-bus/locks.json
echo "{}" > .message-bus/worker-status.json

3. Find Ready Tasks

Tasks are ready when all their `depends_on` tasks are complete.

4. Dispatch Workers in Parallel

Spawn multiple Claude sessions for conflict-free tasks:

# Spawn parallel workers (max 5 concurrent)
claude --print "/orchestrator-supaconductor:task-worker {track_id} 1.1" &
claude --print "/orchestrator-supaconductor:task-worker {track_id} 1.2" &
claude --print "/orchestrator-supaconductor:task-worker {track_id} 2.1" &

# Wait for batch to complete
wait

5. Monitor Progress

# Check for completion events
ls .message-bus/events/TASK_COMPLETE_*.event
ls .message-bus/events/TASK_FAILED_*.event

6. Handle Failures

• Isolate failed tasks
• Continue with unblocked tasks
• Mark failed tasks for FIX step

7. Repeat Until Done

Find next batch of ready tasks and dispatch.

Worker Pool Limits

• Maximum 5 concurrent workers
• 30-minute timeout per worker
• Heartbeat required every 5 minutes

Output

PARALLEL EXECUTION COMPLETE
WORKERS SPAWNED: X
TASKS COMPLETED: Y
TASKS FAILED: Z

State Update

After all parallel groups complete:

• Set `current_step = "EVALUATE_EXECUTION"`
• Set `step_status = "NOT_STARTED"`

Message Bus

echo "PASS" > .message-bus/events/PARALLEL_COMPLETE_{track_id}.event

Reference

Full agent instructions: `.claude/agents/orchestrator-supaconductor:parallel-dispatcher.md`