用途:该技能面向多智能体并行任务编排场景。它通过定义统一的工作子智能体角色,把同一套四步流程(Step 1 初始化、Step 2 处理、Step 3 校验、Step 4 收尾)分派给多个并行工作单元,同时让各工作单元在执行过程中主动上报里程碑进度,从而让父编排器掌握“飞行中”的实时状态,而非只能等待最终结果。
主要能力:
- 注册自定义工作角色。调用 define_subagent 注册名为 pipeline_step_runner 的子智能体,其职责描述为执行四步流程并通过 send_message 上报每个里程碑的完成情况;配置中启用写工具(enable_write_tools 为 true),关闭 MCP 工具与子智能体工具。
- 并行分派。获取父编排器的会话 ID(如 parent-123),在一次 invoke_subagent 调用中以 TypeName "pipeline_step_runner" 并发派发 3 个工作单元(Dataset Ingestion Worker、Image Processing Worker、Model Inference Worker),每个单元设置 Role 为对应工作单元的名称,并在 Prompt 中要求向指定 Recipient 发送步骤完成负载。
- 遥测处理与实时看板。子智能体发来的 send_message 事件会以响应式方式到达,父编排器解析 JSON 遥测负载并渲染或更新合并的实时状态看板,逐行展示每个工作单元的名称、进度条与当前步骤(如“Step 2/4 Complete (Process)”)。
- 汇总与最终报告。收到所有后台子智能体的 Step 4 完成回调后,合成最终指标与总耗时,向用户呈现完成摘要并给出可执行的后续步骤。
使用方式:按资料描述,流程为先调用 define_subagent 注册工作角色,再获取父编排器会话 ID,然后用 invoke_subagent 并发派发工作单元,接着在对话中响应式处理 send_message 事件并解析 JSON 负载更新看板,最后在收齐全部收尾回调后输出汇总。子智能体系统提示要求步骤之间暂停 5 秒,负载格式为结构化 JSON:{"worker": "", "step": <step_number>, "name": "", "status": "COMPLETE"}。
适用场景:适合需要并行执行多个流水线任务、并希望实时看到各单元阶段进度的编排演示,例如数据摄取、图像处理、模型推理等多路任务同时推进时的进度跟踪。
限制:当前资料仅提供一个演示性流程与固定四步结构,具体接入的实际业务逻辑、部署平台与运行环境暂未提供;进度看板中的进度条为示例样式,非通用组件说明;配置项与工具开关的具体行为细节暂未提供。