Files

5.6 KiB
Raw Permalink Blame History

tags, create time
tags create time
coordinator
多agent
编排
并行
feature-flag
2026-06-09 22:30

COORDINATOR_MODE — 多 Agent 编排

概述

COORDINATOR_MODE 将 CLI 变为"编排者"角色。编排者不直接操作文件,而是通过 AgentTool 派发任务给多个 worker 并行执行。适用于大型任务拆分、并行研究、实现+验证分离等场景。

[!info] Feature Flag: FEATURE_COORDINATOR_MODE=1 + 环境变量 CLAUDE_CODE_COORDINATOR_MODE=1 实现状态:编排者完整可用,worker agent 为通用 AgentTool worker

正文

核心约束

  • 编排者只能使用:Agent(派发 worker)、SendMessage(继续 worker)、TaskStop(停止 worker)
  • Worker 可以使用所有标准工具(Bash、Read、Edit 等)+ MCP 工具 + Skill 工具
  • 编排者的每条消息都是给用户看的;worker 结果以 <task-notification> XML 形式到达

用户交互

启用方式

FEATURE_COORDINATOR_MODE=1 CLAUDE_CODE_COORDINATOR_MODE=1 bun run dev

需要同时设置 feature flag 和环境变量。CLAUDE_CODE_COORDINATOR_MODE 可在会话恢复时自动切换(matchSessionMode)。

典型工作流

sequenceDiagram
    participant U as 用户
    participant C as 编排者
    participant WA as Worker A
    participant WB as Worker B
    
    U->>C: 修复 auth 模块的 null pointer
    C->>WA: Agent({ description: "调查 auth bug", prompt: "..." })
    C->>WB: Agent({ description: "研究 auth 测试", prompt: "..." })
    WA-->>C: task-notification: 在 validate.ts:42 发现 null pointer
    WB-->>C: task-notification: 测试覆盖情况...
    C->>WA: SendMessage({ to: "agent-a1b", message: "修复 validate.ts:42..." })
    WA-->>C: task-notification: 修复完成
    C->>WB: Agent({ description: "验证修复", prompt: "..." })
    WB-->>C: task-notification: 验证通过
    C->>U: 综合报告

实现架构

模式检测

文件:src/coordinator/coordinatorMode.ts:36-41

export function isCoordinatorMode(): boolean {
  return feature('COORDINATOR_MODE') &&
    isEnvTruthy(process.env.CLAUDE_CODE_COORDINATOR_MODE)
}

会话模式恢复

matchSessionMode(sessionMode) 在恢复旧会话时检查存储的模式,如果当前环境变量与存储不一致,自动翻转环境变量。防止在普通模式下恢复编排会话(或反之)。

Worker 工具集

getCoordinatorUserContext() 告知编排者 worker 可用的工具列表:

  • 标准模式:ASYNC_AGENT_ALLOWED_TOOLS 排除内部工具(TeamCreate、TeamDelete、SendMessage、SyntheticOutput)
  • Simple 模式(CLAUDE_CODE_SIMPLE=1):仅 Bash、Read、Edit
  • MCP 工具:列出已连接的 MCP 服务器名称
  • Scratchpad:如果 GrowthBook tengu_scratch 启用,提供跨 worker 共享的 scratchpad 目录

系统提示

文件:src/coordinator/coordinatorMode.ts:111-369

编排者系统提示(getCoordinatorSystemPrompt())约 370 行,包含:

章节 内容
1. Your Role 编排者职责定义
2. Your Tools Agent/SendMessage/TaskStop 使用说明
3. Workers Worker 能力和限制
4. Task Workflow Research -> Synthesis -> Implementation -> Verification 流程
5. Writing Worker Prompts 自包含 prompt 编写指南 + 好坏示例对比
6. Example Session 完整示例对话

Worker Agent

文件:src/coordinator/workerAgent.ts

当前为 stub。Worker 实际使用通用 AgentTool 的 worker subagent_type。

数据流

flowchart TD
    A["用户消息"] --> B["编排者 REPL 受限工具集"]
    B --> C{"工具选择"}
    C -->|"Agent"| D["Agent({ subagent_type: 'worker', prompt: '...' })"]
    D --> E["Worker Agent 完整工具集"]
    E --> F["执行任务 Bash/Read/Edit/..."]
    F --> G["返回 task-notification"]
    C -->|"SendMessage"| H["SendMessage({ to: 'agent-id', message: '...' })"]
    H --> I["继续已存在的 Worker"]
    C -->|"TaskStop"| J["TaskStop({ task_id: 'agent-id' })"]
    J --> K["停止运行中的 Worker"]

关键设计决策

  1. 双开关设计:feature flag 控制代码可用性,环境变量控制实际激活。允许编译时包含但不默认启用
  2. 编排者受限:只能用 Agent/SendMessage/TaskStop,确保编排者专注于派发而非执行
  3. Worker 不可见编排者对话:每个 worker 的 prompt 必须自包含(所有必要上下文)
  4. 并行优先:系统提示强调"Parallelism is your superpower",鼓励并行派发独立任务
  5. 综合而非转发:编排者必须理解 worker 发现,再写出具体的实现指令。禁止 "based on your findings" 类懒惰委托
  6. Scratchpad 可选共享:通过 GrowthBook 门控的共享目录,让 worker 之间持久化共享知识

使用方式

# 基本启用
FEATURE_COORDINATOR_MODE=1 CLAUDE_CODE_COORDINATOR_MODE=1 bun run dev

# 配合 Fork Subagent
FEATURE_COORDINATOR_MODE=1 FEATURE_FORK_SUBAGENT=1 \
CLAUDE_CODE_COORDINATOR_MODE=1 bun run dev

# Simple 模式(worker 只有 Bash/Read/Edit)
FEATURE_COORDINATOR_MODE=1 CLAUDE_CODE_COORDINATOR_MODE=1 \
CLAUDE_CODE_SIMPLE=1 bun run dev

文件索引

文件 行数 职责
src/coordinator/coordinatorMode.ts 370 模式检测 + 系统提示 + 用户上下文
src/coordinator/workerAgent.ts — Worker agent 定义(stub)
src/constants/tools.ts — ASYNC_AGENT_ALLOWED_TOOLS 工具白名单

关联笔记