dsh-kimicode-swarm

dsh-kimicode-swarm — DeepSeek Harness 批量并行子 Agent 调度

---

把 Kimi Code Swarm 模式（主从式多 Agent 并行）搬进 DeepSeek Harness：主 Agent 把任务 拆成互不依赖的子任务，swarm_batch 一次批量派发，子 Agent 并行执行，完成后汇总—— 官方基准下端到端效率最高提升 4.5 倍。聊天内实时进度条：每个子 Agent 一行状态 （排队 / 运行中 / 完成），像 Kimi 的 TUI 一样看着任务逐个点亮。

特性

• swarm_batch 工具：prompt_template + items 批量生成子任务（最多 128 项）， 每项可带 model / type；resume_agent_ids 断点续做。
• 自适应调度（对齐 Kimi SubagentBatch 调度合约）：先 5 个并发 + 每 700ms 爬坡 1 个； 撞限流指数退避（3s/6s/12s…）并自适应收缩/恢复并发容量；用户取消保留已完成结果； 单任务超时只失败该任务。
• /swarm 命令：一次性 Swarm 模式——探索边界、拆解子任务、批量派发、 汇总结果、自动退出模式（对齐 Kimi 的 task 触发语义）。
• 聊天内实时进度条：host 端每步状态变化发 swarm/progress 会话事件，浏览器端 经 mux 流订阅渲染，运行中蓝点脉冲、排队灰点、完成绿点。
• 模型三级分配：item 级/整批显式 model > 设置映射表（按 type 命中）> 继承调用者 模型（默认，由 Agent 自由分配）。

架构

┌─ host 半区（node 进程，src/index.ts）─────────────────────────┐
│  swarm_batch 工具（ctx.tools.register）                        │
│    ├─ 参数归一化（core/normalize.ts）：模板填充 / 模型解析 / 去重 │
│    ├─ SwarmScheduler（core/scheduler.ts）：两阶段自适应并发调度  │
│    │    └─ onProgress 回调：每步状态变化                        │
│    ├─ ctx.subagents.start()：真实子 Agent 启动（继承调用者模型） │
│    └─ session.append('swarm/progress')：进度事件（src/events.ts）│
│  /swarm 命令（ctx.commands.register）：一次性 Swarm 模式指令     │
│  设置命名空间 + 系统提示词公告                                  │
└──────────────────────────────────────────────────────────────┘
                            │ mux 事件流（透传所有 session 事件）
┌─ browser 半区（Web GUI，src/client/）─────────────────────────┐
│  progress-store.ts：模块级进度订阅（mux 流 → 按 callId 分发）    │
│  SwarmCard.tsx：tool.call.toolview keyed 视图                   │
│    ├─ 运行中：每子 Agent 一行实时状态（排队/运行中/完成）        │
│    └─ 完成后：结果面板（每行可展开，汇总自 presentationMeta）    │
│  SwarmSettingsCard.tsx：设置卡片（模型映射表，模型目录动态拉取）  │
└──────────────────────────────────────────────────────────────┘