用途:该技能让智能体端到端驱动 pueue(守护进程式 shell 任务队列),提交单个任务或整个 DAG、按组限制并行度、阻塞等待完成、获取日志并重试。它是 CLI 桥接层,不是调度器。
主要能力:pueued 守护进程持有队列状态,任务以整数 id 标识,组是带独立并行上限的命名队列,依赖通过 pueue add --after 表达(仅 AND、仅成功)。提供脚本:check-daemon.sh(健康检查,可选自动启动)、submit.sh(提交单任务,返回 JSON)、wait.py(阻塞至终态并输出 JSON 摘要)、submit-dag.py(声明式 DAG 提交,拓扑排序与校验)、cleanup.sh(清理历史、空组与旧日志)。
使用方式:先运行 check-daemon.sh --start --json 确认守护进程;用 pueue group add ml 与 pueue parallel 4 --group ml 建组限流;提交示例:bash skills/local/pueue-job-queue/scripts/submit.sh --label train-baseline --group ml -- python train.py --seed 1。DAG 示例:submit-dag.py dag.yaml --label-prefix nightly- --isolated-group。等待:wait.py --ids 17,18,19 或 --group ml 或 --label-prefix nightly-。日志与重试:pueue log --json --full 17、pueue restart --in-place 17、pueue kill 17 && pueue remove 17。
适用场景:批量命令限并发、长任务跨重启持久化、成功依赖的扇出/扇入流水线、延迟调度、阻塞等待并汇总结果。
限制:--after 仅 AND 且仅成功,无 OR、失败重试或条件分支;并行度由组而非依赖图决定;pueue 不自动建组;pueue wait 即使任务失败也返回 0;日志位于平台特定目录;跨主机调度需改用 Airflow/Dagster/Prefect/Slurm。