sync-parallel

Sync Parallel Agent Execution

Coordinate and synchronize multiple agents working in parallel, detect conflicts, and reassign work as needed.

Primary Responsibilities

1. Read all active communication files
2. Identify completed tasks and blockers
3. Detect and resolve conflicts
4. Reassign work if needed
5. Generate comprehensive status reports

Synchronization Protocol

Step 1: Gather Agent Status

# Read all communication files
for comm_file in .squad/comms/agent-*-comm.md; do
  agent_id=$(basename "$comm_file" -comm.md)
  status=$(grep "^Status:" "$comm_file" | tail -1 | cut -d: -f2)
  echo "$agent_id: $status"
done

Step 2: Analyze Current State

## Parallel Execution State Analysis

### Active Agents
| Agent ID | Status | Current Task | Progress | Blockers |
|----------|--------|--------------|----------|----------|
| agent-1 | ACTIVE | Dashboard UI | 3/5 tasks | None |
| agent-2 | BLOCKED | API endpoints | 2/4 tasks | Waiting for types |
| agent-3 | ACTIVE | ML pipeline | 1/3 tasks | None |

### File Lock Status
| File | Locked By | Duration | Status |
|------|-----------|----------|--------|
| /frontend/Dashboard.tsx | agent-1 | 2 min | Active |
| /shared/types/metrics.ts | agent-1 | 8 min | ⚠️ Long |

### Completed Tasks
- ✅ Frontend layout structure (agent-1)
- ✅ Database schema (agent-2)
- ✅ Base ML model selection (agent-3)

Step 3: Detect Conflicts

# Conflict detection algorithm
def detect_conflicts():
    conflicts = []
    
    # Check for lock conflicts
    for lock_file in locks:
        if lock_duration > 10_minutes:
            conflicts.append({
                'type': 'STALE_LOCK',
                'file': lock_file,
                'agent': lock_owner,
                'duration': lock_duration
            })
    
    # Check for file conflicts
    modified_files = get_git_modified()
    for file in modified_files:
        owners = get_file_owners(file)
        if len(owners) > 1:
            conflicts.append({
                'type': 'MULTIPLE_MODIFICATIONS',
                'file': file,
                'agents': owners
            })
    
    # Check for dependency blocks
    for agent in blocked_agents:
        if agent.blocked_duration > 15_minutes:
            conflicts.append({
                'type': 'LONG_BLOCK',
                'agent': agent.id,
                'waiting_for': agent.blocker,
                'duration': agent.blocked_duration
            })
    
    return conflicts