Skip to content
IN DEVELOPMENT编排Trinity混合引擎Signal-drivenNode.jsv0.1.8

Agent 任务编排

Trinity 三层委托 + Signal-driven 轮询

Trinity 架构:Strategist 以用户身份自主拆解/监控/验收。Lieutenant (dispatch.mjs) 自动调度 Builder。Signal-driven 轻量轮询保护上下文。Codex / Claude Code 混合引擎,实时 Dashboard。

Agent 任务编排
混合引擎:不同任务使用不同引擎
$node scripts/dispatch.mjs ./tasks/ --dry-run --parallel
OK Tasks: 3 — T1[codex], T2[claude], T3[codex]
OK Engine: mixed (2 codex, 1 claude)
OK DAG: T1+T2 → T3
Signal-driven 轮询 (20 tokens)
$cat ./tasks/.dispatch-logs/{runId}/signal
RUNNING
$cat ./tasks/.dispatch-logs/{runId}/signal
COMPLETED
$cat ./tasks/.dispatch-logs/{runId}/digest.txt
OK 3 passed | 0 failed | +150/-20 lines

核心能力

Trinity 三层架构

Commander(用户) → Strategist(你) → Lieutenant(dispatch.mjs) → Builder(Codex/Claude)。Strategist 以用户身份自主决策。

Signal-driven 轮询

通过 cat signal (~20 tokens) 获取状态。RUNNING/COMPLETED/ATTENTION/FAILED/FATAL 五种信号。保护上下文不被爆。

混合引擎

每个任务可独立选择 Codex 或 Claude Code 引擎。Task Spec 中 engine 字段指定,未指定则继承全局默认值。

自主决策循环

POLLING → EVALUATING → DECIDING → ACTING。检测到完成立即评估+决策+行动,从不停止等待指令。

检查点恢复

--resume 恢复上次运行,--retry-failed 仅重跑失败任务。Lieutenant 内置 429/超时自动重试。

实时 Dashboard

DAG 依赖图(SVG)、Agent 事件流、Token 用量追踪、进度条。默认自动打开浏览器。

预飞行检查

启动前验证 API Key、Git 工作区干净度。问题前置暴露。

命令参考

编排服务

dispatch.mjs — 任务调度

命令说明示例
--dry-run预览执行计划node scripts/dispatch.mjs ./tasks/ --dry-run
--parallel并行调度node scripts/dispatch.mjs ./tasks/ --parallel --approval-mode full-auto
--engine默认引擎(任务可覆盖)node scripts/dispatch.mjs ./tasks/ --engine claude
--resume从断点恢复node scripts/dispatch.mjs ./tasks/ --resume
--resume --retry-failed仅重试失败node scripts/dispatch.mjs ./tasks/ --resume --retry-failed
--status查看状态node scripts/dispatch.mjs ./tasks/ --status

Signal-driven 状态查询

轻量级状态读取 (保护上下文)

命令说明示例
signal~20 tokens,首选cat {taskDir}/.dispatch-logs/{runId}/signal
digest.txt~80 tokens,状态变更时cat {taskDir}/.dispatch-logs/{runId}/digest.txt
status.txt~500 tokens,需详细信息cat {taskDir}/.dispatch-logs/{runId}/status.txt
summary.json完成后结构化报告cat {taskDir}/.dispatch-logs/{runId}/summary.json

Trinity 三层架构

用户 (Commander) ─── 给出初始需求 + 约束 ─── 可随时介入


你 (Strategist) ── 用户的战略代理 ── 拆解/监控/验收/决策


Lieutenant (dispatch.mjs) ── 自动重试/恢复/调度


Builder (Codex/Claude) ── 执行原子任务 ── 不做架构决策

Strategist 行为准则:

  • 从不等待:检测到完成 → 立即评估 → 立即决策 → 立即行动
  • 产品思维:拆任务想"用户要什么",不是"代码怎么分"
  • 一个 session = 一个可验证交付物

全流程闭环

用户需求 → Analyze → Decompose → Dispatch → Autonomous Loop

                                    全部成功 → 最终报告
                                    部分失败 → resume --retry-failed
                                    需要更多 → 规划下一批次 → Decompose

Phase 1: Analyze (分析)

读取 domain.md + AGENTS.md + 目录结构,产出需求分析摘要。

Phase 2: Decompose (拆解)

粒度阈值:

维度阈值超出则拆分
文件变更数≤ 8 个文件按模块边界拆
代码行数≤ 500 行按功能切片拆
依赖深度≤ 2 层先交付底层
验收点≤ 3 个功能过于复杂
上下文复杂度≤ 200 字描述不清 = 范围太大

三种策略: 垂直切片 (Feature-based) | 水平分层 (Layer-based) | 契约先行 (Contract-first)

Phase 3: Dispatch (派发)

bash
# 安装依赖
cd agent-task-orchestration && npm install

# 并行调度,全自动模式
node scripts/dispatch.mjs ./tasks/ --parallel --approval-mode full-auto

# 查询状态 (零开销)
cat ./tasks/.dispatch-logs/{runId}/signal

Lieutenant 自动处理 (无需 Strategist 介入):

  • 限流 429 → 指数退避重试 (≤3次)
  • 网络超时 → 自动重试
  • 单任务失败 → 跳过下游,持久化 checkpoint
  • 任务超时 → 按预估自动终止 (S=30min, M=60min, L=120min)
  • Token 告警 → signal 写入 ATTENTION token_budget_exceeded

Phase 3.5: Autonomous Loop (自主决策循环)

Signal-driven 轮询协议:

1. cat signal
   ├─ RUNNING           → sleep 60s → 回到 1
   ├─ COMPLETED         → cat digest.txt → 进入 EVALUATING
   ├─ ATTENTION (failed) → cat digest.txt → 评估: retry/skip/report
   ├─ ATTENTION (token)  → 决策: 等待/终止
   ├─ FAILED            → cat digest.txt → 决策: resume/skip/report
   └─ FATAL             → cat digest.txt → 报告用户

轮询节奏: 刚启动 30s → 运行中 60s → 接近完成 30s

上下文保护:

  • ❌ 禁止 command_status 读终端输出
  • ❌ 禁止读 state.json events 数组
  • ✅ 首选 signal 文件 (~20 tokens)
  • ✅ 次选 digest.txt (~80 tokens)

Phase 4: Quality Gate (质量门禁)

检查项何时执行
构建每批次完成后
Lint代码变更批次
测试功能实现批次
diff 范围每批次完成后

审计/文档类批次可跳过构建检查。

SDK 模式映射

CLI 模式Codex approvalPolicyCodex sandboxModeClaude permissionMode
suggeston-requestworkspace-writedefault
auto-editon-failureworkspace-writeacceptEdits
full-autoneverworkspace-writebypassPermissions

参考文档

文档用途何时读取
trinity-protocol.md三层委托完整规格首次使用或决策不确定时
task-decomposition.md拆解方法论深入指南Phase 2
codex-patterns.mdCodex CLI 配置Phase 3
quality-gate.md质量门禁模板EVALUATING 阶段

快速开始

Install
via skills.sh (推荐)
$npx skills add northseadl/norix-skills/agent-task-orchestration
或手动安装
$git clone https://github.com/northseadl/norix-skills.git
$ln -s norix-skills/agent-task-orchestration <SKILLS_DIR>/agent-task-orchestration
验证
$node scripts/dispatch.mjs --help
OK Skill ready.

Built for AI Agents, by Norix