高可用编排器 minhdevtry/dsh-orchestrator

HA Orchestrator — 模型恢复与多智能体编排

HA Orchestrator

HA Orchestrator 是 DeepSeek Harness (dsh) 的一个插件：

- 当模型调用在运行中途失败时，它会在备用模型上重试，运行得以继续。
- 它新增了一个 orchestrate 工具，当任务适合时模型会自行调用它，将工作拆分到多个子智能体上并行执行（fanout）、分阶段执行（pipeline），或通过审查与归约阶段执行（supervisor、map-reduce、router）。

设置页面还允许你定义自定义子智能体（或用 AI 生成一个），并且 UI 和提示词文案提供中文和英文版本，跟随你的 DSH 语言设置。

可靠的模型恢复。并行工作。可审查的交付。

HA Orchestrator 在模型失败时保持长时间运行的 DSH 会话继续推进，然后将复杂工作转化为可观察、并发的子智能体运行，并产出证据充分的结果。

| 🛡️ 挺过模型故障 | ⚡ 横向扩展工作 | ✅ 自信交付 |
| 备用轮换、冷却、提供商熔断和恢复探测，让失败的模型不会终结整个运行。 | 五种编排模式覆盖并行研究、分阶段计划、路由、归约和监督审查。 | 预算、运行历史、可恢复性、结构化输出和审查阶段，让最终结果可被检查。 |

最适合： 深度研究、大型代码库阅读、批量审查、多方案对比以及实现规划。

它能做什么

模型失败时进行故障转移

- 当模型请求出错时，会在下一个备用模型上重试。备用模型按顺序尝试。
- 失败的模型会被暂时跳过并进入冷却；冷却期结束后它会自行恢复。
- 它支持突发窗口失败计数、提供商级熔断、低成本恢复探测，以及可选的上下文窗口降级。
- 每个失败事件都有重试预算。一旦预算耗尽，插件就会停止重试，而不是无限循环。
- 如果模型错误中断了运行，插件会重启任务一次，以免工作丢失。

备用模型、冷却时间、失败阈值和错误码过滤器可在“设置”→“HA 与编排”中配置。

编排，自动触发

orchestrate 工具在每个会话中都可用。它的描述以及系统提示中的一条提示会告诉模型，当任务包含可并行的部分、分阶段运行或需要一轮审查时，应自行调用它：

- fanout — 拆分任务，并行运行子任务，合并结果。
- pipeline — 按顺序运行各阶段；每个阶段的输出馈入下一个阶段。
- supervisor — 并行运行子任务，然后让一个监督子代理审查并合并它们。
- map-reduce — 并行运行 map 任务，然后将它们的输出发送给一个归约子代理。
- router — 将一组候选任务发送给一个路由子代理，由其选择或路由这些工作。

该工具还支持已保存的预设、恢复中断的运行、监督审查轮次、多个审查者、每次运行的子代理预算、结构化输出模式，以及按代理的工具允许/拒绝列表。默认情况下，来自子代理的嵌套编排会被拒绝。

如果某次运行没有自行编排，只需说“use orchestration”。

注意：如果当前会话使用 complete: true 的角色预设，例如 minimal / minimal-v3，平台会有意丢弃插件的系统提示部分；此时自动触发仅依赖 orchestrate 工具的描述。插件现在已在该描述中加入“read a large project”，但如果仍未触发，只需说“use orchestration”。

你也可以关闭自动触发：在“设置”→“HA 与编排”→System 卡片中，关闭 context injection。此后模型只会在你要求时进行编排，例如“use the dsh-ha-orchestrator plugin”。

子代理默认不会收到此上下文注入，以防止它们被提示启动嵌套编排。如果你希望子代理看到相同的上下文，请在 System 卡片中启用 Also inject into subagents。

自定义子代理

在设置页面中定义可复用的子代理：名称、提供商/模型、模型 effort、描述、系统提示，以及可选的工具允许/拒绝列表。每个角色还可以定义自己有序的 fallbacks 模型链，并为每个回退项指定 provider/model@effort；启动失败或子模型错误会在该角色自己的链上重试，而不会读取全局 HA 备用列表。任务按名称选择它们，模型可以随时查找该列表。当所选提供商支持结构化输出时，单个任务还可以请求输出提示或对象根 JSON Schema。“AI Generate”按钮接收一句需求描述，并让当前模型填写完整定义。

语言设置界面和所有提示文案均提供中文和英文版本。插件会跟随你的 DSH 语言选择，如果语言包加载失败则回退到中文。你也可以在“System”卡片中固定语言。

安装

要求：带有 web profile 的 DeepSeek Harness。已发布的包无需本地构建步骤；DSH 会提供对等运行时服务。

方法 1：从 npm 安装（推荐）

该包以 dsh-ha-orchestrator 为名发布在 npm 上：

1. 运行一键安装命令：

dsh plugin --profile web add dsh-ha-orchestrator

2. 由于该包声明了 dsh.bundle.patch，dsh plugin add 会自动将 dsh-ha-orchestrator 添加到 dsh.profile.bundles，并应用 cordis.patch.yml。无需手动添加组合行。
3. 无需重启：bundle-patch 层会热重载（Cordis HMR），因此插件会在正在运行的进程中激活。刷新浏览器页面以加载设置界面。插件也会在启动时加载，并在重启后继续存在。

方法 2：从本地检出安装（开发）

用于开发或测试未发布版本。要求 PATH 中有 pnpm：

1. 运行一键安装命令：

dsh plugin --profile web add "file:"

2. 由于该包声明了 dsh.bundle.patch，dsh plugin add 会自动将 dsh-ha-orchestrator 添加到 dsh.profile.bundles，并应用 cordis.patch.yml。无需手动添加组合行。
3. 无需重启：bundle-patch 层会热重载（Cordis HMR），因此插件会在正在运行的进程中激活。刷新浏览器页面以加载设置界面。插件也会在启动时加载，并在重启后继续存在。

方法 3：手动安装（无 pnpm）

1. 将此仓库克隆/复制到你的 DSH profile 中：~/.dsh/profiles/web/node_modules/dsh-ha-orchestrator
2. 将其添加到组合文件 ~/.dsh/profiles/web/cordis.patch.yml：

- insert:
- id: dsh-ha-orchestrator
name: dsh-ha-orchestrator

3. 无需重启：profile patch 层会热重载（Cordis HMR），因此插件会在正在运行的进程中激活。刷新浏览器页面以加载设置界面。插件也会在启动时加载，并在重启后继续存在。

版本说明： v0.1.0 是之前的动态构建版本，通过 cordis_define 按会话部署，仅作为功能预览发布。从 v0.2.0 开始，插件为静态插件，并随 DSH 在启动时加载。从引入 bundle patch 的版本开始，推荐使用方法 1（一键安装）。

用法

正常使用无需特殊说明——模型会自行决定何时进行编排：

You: Research these three open-source projects, compare licenses and community activity, and recommend one.
模型：看到 3 个独立子任务 → 调用 orchestrate（扇出）→ 并行研究 → 比较 → 推荐

你： 阅读这个大型项目，并总结其架构和当前进展。
模型：将其拆分为独立的按模块/文档/代码阅读任务 → 调用 orchestrate（扇出）→ 并行读取 → 整合架构和进展

你： 先做需求分析，然后写设计文档，再制定实现计划。
模型：调用 orchestrate（流水线）→ 每个阶段的输出馈入下一阶段

你： 写一份竞争分析报告，并让一位资深评审员审核。
模型：调用 orchestrate（监督者）→ 并行分析 → 审核并合并 → 报告

展示

配置模型恢复，观察并行工作进展，检查每个子代理实际使用的模型，并在运行结束后审计该次运行。

注意：这些截图来自 v0.12.x。

命令

该插件还注册了两个可选的斜杠命令，用于检查和运行时状态管理：

| 命令 | 描述 |
| /ha | 显示当前 HA 状态（与 /ha status 相同）。 |
| /ha status | 显示隔离、失败计数、轮换游标、切换历史和探测日志。 |
| /ha diag | 显示插件诊断信息：服务可用性、持久化、语言和注入状态。 |
| /ha reset | 清除隔离、失败计数、游标和历史。 |
| /ha probe | 手动探测模型以验证恢复。 |
| /orchestrate | 列出最近的 orchestrate 运行（与 /orchestrate runs 相同）。 |
| /orchestrate runs | 列出最近 24 次 orchestrate 运行（每次附带一行结果摘要）。 |
| /orchestrate show | 显示特定 orchestrate 运行的详细信息。 |
| /orchestrate presets | 列出已配置的编排预设。 |
| /ha-orch-resume | 按 runId 恢复未完成的编排运行：复用已完成的子任务，仅运行其余部分。 |

这些命令通过 DSH commands 服务注册。如果某个部署未提供该服务，插件仍可正常工作；只是这些斜杠命令不可用。

如果宿主提供 skills 服务，该包还会注册一个捆绑的 dsh-ha-orchestrator 技能，供用户显式调用。它包含使用和故障排除指南；它不会作为可被模型自动调用的技能暴露。

设置

设置 → “HA 与编排”：

顶部的概览横幅会一目了然地显示 HA 状态、当前默认模型、备份数量、编排状态和活动运行。

| 卡片 | 你可以做什么 |
| 模型高可用 | 开/关、备份列表（结构化行，支持内联下拉编辑、“推荐备份”以及空状态引导），以及一个“高级”部分，用于冷却时间、失败阈值、突发窗口、提供商熔断阈值、探测恢复、上下文溢出降级、错误码过滤、持久化选择以及停止转向 |
| 子代理编排 | 开/关、提供商、默认并发数（6）、每次运行的最大子代理数（16）、全局并发上限、流水线重试、合并/渲染限制、委托深度限制以及子代理输出令牌限制——分组为 基础 / 并发与预算 / 高级 |
| 自定义子代理 | 添加、编辑、重新排序、删除（头像 + 模型/投入等级徽章）；内置的 reviewer/researcher/research-merger 定义；“AI 生成”根据描述创建一个；工具允许/拒绝列表、按角色的输出令牌限制，以及按角色的回退链，可在不读取全局 HA 备份列表的情况下处理启动失败和子模型错误 |
| 诊断 | HA 运行时（当前默认、带级别和冷却倒计时的隔离、失败计数、游标、探测、故障转移历史、重置）以及可展开的最近运行（模式徽章、持续时间、带 lastKey 的每子任务状态表、结果摘要——历史在重启后仍保留） |
| 系统 | 插件语言（跟随系统 / 中文 / 英文）、编排提示开关、实时注入状态、一键配置导出/导入以及调试卡片开关 |

在对话过程中，你还会获得两个实时视图：

- 编排运行卡片（在对话流中）：带百分比的实时进度条、每子任务状态点、每个子代理实际使用的模型（lastKey），完成后显示 runId 和输出摘要。
- HA 状态胶囊（工具区域）：折叠为一行（已启用 / 备份 / 已隔离 / 上次故障转移）；点击可展开冷却倒计时、最近的故障转移和活动运行。

文档

- 架构 — 模块、数据流、服务契约
- 配置 — 每个配置键及其默认值和钳制规则
- 安全 — 信任边界和已应用的加固
- 验证与发布 — 测试矩阵、门禁、发布步骤
- 兼容性 — 已验证的 DSH 快照和对等策略

说明

- 配置和 HA 状态会在会话工作区 / DSH_HOME 中查找，然后是在沙箱 workspace-write 根目录中查找。如果两个位置都不可用，配置写入会报告持久化诊断。当不存在候选目录时，运行记录和 Markdown 运行产物还会回退到 fs 服务的默认 cwd。
- HA 运行时状态（隔离、失败计数器、轮换游标、切换历史）以 500 毫秒防抖持久化到 dsh-ha-orchestrator.ha.json，并在启动时恢复。编排运行记录到 dsh-ha-orchestrator.runs.jsonl（最多 200 条磁盘记录 / 50 条内存记录），同时也会写入为 dsh-ha-orchestrator.run-.md 产物，其中包含完整的子任务输出。
- 运行记录和产物可能包含任务提示和模型输出；请确保工作区仅对受信任的用户/进程可读。
- 所有 /ha 和 /orchestrate 斜杠命令均列在上文的命令部分中。

许可证

MIT © Saktawdi