circuit-breaker-reporter 是一个多智能体并行编排的演示技能,重点展示实时遥测上报与硬熔断机制。
用途:编排多个并行 worker 子智能体执行流水线任务,在工作过程中实时接收进度与错误消息,并在出现不可恢复的 worker 错误时统一终止所有后台进程。
主要能力:
- 通过 define_subagent 注册专用 worker 人格(示例为 pipeline_step_runner),该人格执行四步流程(Init、Process、Validate、Finalize),每步之间暂停 5 秒,并在每步完成后通过 send_message 向父编排器上报 COMPLETE 状态;若发生不可恢复错误则上报 FATAL_ERROR 并停止执行。
- 通过 invoke_subagent 在一次调用中并发派发 6 个 worker,包括 Dataset Ingestion、Image Processing、Model Inference、Database Sync、Cache Prewarming、Telemetry Export;示例中将 Database Sync Worker 设计为在 Step 2 模拟数据库死锁并上报 FATAL_ERROR,以保证确定性触发熔断。
- 根据 send_message 事件更新实时状态仪表盘,展示各 worker 的步骤进度。
- 当任一子智能体上报 FATAL_ERROR 时,立即调用 manage_subagents 的 kill_all 动作终止进程树中所有运行中的 worker,并自动清理临时工作区分支。
- 成功时汇总最终指标并给出完成摘要;熔断触发时输出故障复盘,说明失败 worker 角色、步骤编号与错误详情,并确认所有后台进程已终止。
使用方式:按工作流步骤先注册 worker 人格,再获取父编排器会话 ID,随后用 invoke_subagent 并发派发 worker 并指定 Role 与 Prompt,最后监听 send_message 事件并调用 manage_subagents 执行熔断。示例中出现的具体参数、角色名与提示词内容均为演示配置。
适用场景:多智能体并行流水线编排、子智能体进度遥测、故障传播与统一终止策略的演示与验证。
限制:当前资料为演示性质,未提供正式产品化部署说明、安装命令、平台依赖、收费信息或性能指标;示例中的失败注入为测试用设计,实际使用需根据具体运行环境调整。