SuperAPI AI 工具集

dag-task-scheduler

通用与其它

查看项目

更新于 10-15 20:30

技能介绍

用途:为有向无环图(DAG)生成最优执行调度,通过波次(wave)并行、资源分配与执行时序管理,在满足约束的前提下提升吞吐量。

主要能力:1)波次调度:将相互独立的任务归入同一并行波次,波次之间顺序执行,并在资源限制内最大化并发。2)资源管理:分配 CPU、内存与 Token 预算,避免并行任务间资源争用,均衡负载。3)优先级处理:在波次内按优先级调度,处理紧急任务与截止时间,必要时支持抢占。4)自适应调度:根据运行时反馈调整计划,处理提前完成与迟到任务,支持动态重排。

使用方式:输入来自 dag-dependency-resolver 的已排序波次,输出供 dag-parallel-executor 使用的执行计划;进度上报给 dag-execution-tracer,重排请求来自 dag-dynamic-replanner。核心函数 scheduleDAG(waves, dag, config) 接收波次、DAG 与调度配置,返回 ScheduledWave 数组,包含波次编号、任务、预计起止时间与资源分配。并行度由 config.maxParallelism 控制(默认 3),超出部分按子波次分组。Token 预算按波次与任务均分。

调度策略:贪心首次适配(简单、开销低,适合任务规模均匀)、最短作业优先(降低平均完成时间,可能饿死长任务)、基于优先级(满足业务要求,需显式指定优先级)、公平共享(防止饥饿,适合多租户)。

失败与适配:支持 stop-on-failure(标记依赖任务跳过)、continue-on-failure(继续执行无依赖任务)、retry-then-skip(重试后跳过)。提前完成时可提前启动依赖波次。

输出与指标:输出 YAML 格式调度计划,含波次、任务、资源摘要、关键路径与瓶颈;指标包括调度延迟、平均波次利用率、并行效率与资源浪费率。

限制:资料未提供具体安装命令、收费方式、支持平台及实际性能数据;调度效果依赖任务时长与资源估算的准确性。