 Blizzard
|
fd145b5852
|
feat(dispatcher): 编排引擎按图执行（拓扑+连线+分支剪枝），弃用线性拍平
旧 compileFlow 把 DSL 图拍平成线性 init→tool…→prompt→model，连线/分支/
memory/aggregate/render 节点全被忽略——"画得出、跑不全"。改为纯 Go 图解释器
(graph.go)，按真实拓扑与连线执行，每种节点 kind 有真实行为：
- input 注入用户输入
- memory 按勾选注入画像/历史（无 memory 节点则沿用默认注入，不回归）
- retriever kb 按 owner 作用域 → kb_search 累计参考资料
- tool 调 MCP 工具，产出进黑板，失败降级不阻断
- agent 据黑板拼消息 → pool 流式回流 token，累计成稿
- aggregate 按策略合并参考资料（拼接/去重合并/摘要）
- render 把成稿经 report_render 渲染 docx
- branch 求值条件 + active-set 剪枝下游（边序约定 [true,false]）
- map 占位（fan-out 暂串行，路线图 Phase 2）
- output 终端
全程逐节点点亮"运行·观测"，token 流与记忆写回保持不变；报告 intent 走原专用
编排不动。compile.go 精简为只留 RunCtx/buildMessages/previewArgs。
实测（gateway+dispatcher+DeepSeek 实跑）：
- input→agent→output 真实流式答复 ✓
- branch 条件 2>1 走分支A、1>2 走分支B（下游真被剪枝）✓
- memory 节点按勾选注入；exec 事件按新节点名(agent:a 等)回流 ✓
- 桌面端 Studio 载示例→运行：4节点3连线校验通过，检索节点 mcp-go 不在时
优雅降级，agent 据空资料如实作答，输出/轨迹面板正常 ✓
路线图 Phase 2：map 真并行 fan-out + aggregate reduce 接上 report 那套；
前端给 branch 的边打 true/false 标签，使条件分支完全精确（当前靠出边顺序约定）。
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
|
2026-06-15 11:42:29 +08:00 |
|
|
Blizzard
|
337d4d7619
|
feat(studio): 完善编排 —— 检索接本人知识库 + 真实模型下拉 + 模板/示例
把编排从"演示桩"接到真实平台：检索节点查本人 owner 隔离的知识库，节点下拉用真实数据。
- dispatcher：makeToolNode 用 task user_id 给检索类工具的 kb 加 owner 前缀（"uid/kb"），
编排里的「检索(RAG)」节点真正命中本人知识库（与隔离对齐）。
- 前端 StudioView：加 identity，载入 /kb/list 与 chat 模型作为「检索.kb」「Agent.model」下拉真值；
Inspector 支持 dynamicOptions（无真值时提示去创建）。
- 编辑体验：示例（一键加载 输入→检索→Agent→输出 可运行图）/ 清空 / 模板名+保存（localStorage，
含布局）/ 载入下拉；ReactFlow deleteKeyCode 支持 Del/Backspace 删节点。
验证：示例图运行 → gateway 发布任务 → dispatcher 编译 → mcp-go 日志 `tool=wiki_search
args=[kb:wt/default ...]`（kb 已按 owner 作用域）→ 命中本人库 → DeepSeek 流式作答；
底部抽屉 完成 ✓ · 工具调用 1。tsc+vite+dispatcher build 通过；重建 .app。
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
|
2026-06-13 16:14:54 +08:00 |
|
|
Blizzard
|
cdc5b3a847
|
feat(observability): 执行可视化 — 节点级实时轨迹（运行·观测）
把任务执行做成可观测：Dispatcher 在每个节点/阶段发结构化 ExecEvent，
经独立 NATS 通道回流，前端逐节点点亮（状态/耗时/工具入参产出）。
- shared: contract.ExecEvent + ExecSubject(sundynix.exec.<id>，与 Token 流分流)；
bus.PublishExec/CompleteExec/SubscribeExec（core NATS，复用结束头）
- dispatcher: execTracer（自增 Seq 保序 + span 自动计耗时）；
Orchestrator 加 ExecSink；通用图(init 召回 / 各 tool 入参→产出 / prompt / model
首token+token数)与报告编排(规划大纲 / 各章并行 start-end / 渲染)全程埋点
- gateway: SubscribeExec + GET /tasks/:id/exec SSE（与 token 流并行）
- desktop: streamExec + deriveNodes(按 node 归并 start/end/error/info)；
复用组件 ExecTrace（竖向轨道，按 kind 着色，运行中脉冲灯）；
新 RunsView(运行·观测：轨迹+输出双栏)；BottomDrawer 轨迹/工具调用 tab 接真实数据；
ReportView 加执行轨迹栏；左导航「运行」置就绪
实测：
- 报告任务 /exec：规划(2680ms,4章) → 4 章并行(seq 交错,各~7-8s 重叠=真并行,
每章带 docs 知识库检索预览+成稿字数) → 渲染(docx 落盘)
- 通用图 /exec：tool:kb_search(678ms,入参→Milvus 产出) → prompt(2消息) →
model(首token 860ms / 4 tokens)
- 浏览器(Preview)：报告页执行轨迹逐节点点亮、章节带耗时/字数/检索片段，完成后下载 Word
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
|
2026-06-12 14:29:28 +08:00 |
|
|
Blizzard
|
71db0e295f
|
feat: compose.NewGraph 全图编译 — 工具节点在 Eino 图里真实执行
dispatcher 按每个任务的 DSL 动态编译 Eino 图：工具/检索节点按拓扑序作为真实图
节点经 NATS 调 MCP，产出注入模型上下文。不再是固定的 recall→prompt→model。
- dsl: 加 Parse(图结构) + (Flow)Topo(Kahn 拓扑序,环退化声明序) + ToolBinding(tool/
retriever 节点→工具名+参数)
- eino/compile.go: 逐任务 compileFlow —— START→init(身份+记忆召回)→tool_n(真调 MCP,
失败降级)→prompt(黑板 RunCtx 组装 system+画像+工具产出+历史+输入)→model→END
- eino/orchestrator: 去掉启动期静态图，Handle 内按 DSL 动态编译；删旧 graph.go/state.go
- 工具节点产出作为参考资料注入 system，模型据此作答
- 验证: 全模块 build✓ + e2e PASS; 真实 DeepSeek 双证——回归(input+agent)→'蓝色';
工具节点(echo 注入事实)→mcp-go 日志证明图里真调 echo→模型据参考资料答'…Milvus…'
注: 分支/并行节点(compose.Branch/fan-out)暂未编译，是更大 TODO。
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
|
2026-06-10 16:45:33 +08:00 |
|