用途:按调度好的 DAG 波次执行任务,在受控并发下编排多个代理并行工作。
主要能力:按波次并发执行任务并等待整波完成后再进入下一波;用 Task 工具为每个节点派生 sub-agent,可选择 haiku、sonnet、opus 等模型与代理类型;跟踪运行状态、完成回调与超时;限制并发数、监控每个代理的 token 使用,防止资源耗尽;支持重试(可配置最大次数、间隔与指数退避)以及 stop-on-failure、continue-on-failure、retry-then-skip 等失败策略;可记录执行状态与进度(已完成/运行中/待处理/失败节点、token 用量与估算成本)。
使用方式:作为技能加载后,接收来自调度器的执行计划,按配置的 maxParallelism 分批并发执行;派生代理时构造 Task 工具参数(description、prompt、subagent_type、model)。输入来自 dag-task-scheduler,结果输出给 dag-result-aggregator,错误交给 dag-failure-analyzer。
适用场景:需要将依赖关系明确的工作拆成多波并行执行、并控制并发与成本的自动化流程。
限制:资料未说明具体安装命令、收费方式与平台要求;并行度、模型选择、超时等均依赖传入的 ExecutorConfig,暂未提供默认值与完整参数说明。