maogeigei
b2e472bf27
- 调度根因修复：工作台/api/run 显式写 next_run_at=now+5s（17列），scheduledAt=now+5s 带秒 - 新增 自动化任务调度机制.md（根因/硬规则/状态机/并发上限≈3/排查命令） - 并发方案A（浏览器锁）：/api/run 对浏览器类任务自动注入锁约束；浏览器搜索抖音账号操作规范.md 新增5.6并发互斥 - 端口 8899→8900 可传参（8899被小米MiPCAudio.exe系统服务占用且杀后复活） - cdp-test-junxi.mjs 支持 --port 参数 - SKILL.md 工作台段落同步修正（旧认知 scheduled_at=now 已废弃） - 俊希全流程 TC-01~11 复测全通过（验收表更新）：并行解析6条+AI写脚本会话链路完整跑通
4.0 KiB
4.0 KiB
自动化任务调度机制（09-01 定稿，实测验证）
本文档固化 08-31~09-01 多次调试理清的客户端自动化调度机制，是工作台
/api/run链路唯一权威说明。 结论均来自本机实测（automations / automation_runs / sessions 三表 + 调度器实际行为），非推测。
一、完整链路
工作台按钮 → POST /api/run → 直写 ~/.workbuddy/workbuddy.db automations 表
→ 客户端调度器按 next_run_at 扫描（周期 ≈30s）
→ 命中 → automation_runs 写 QUEUED → 建会话（sessions 表, is_background_automation=1）
→ IN_PROGRESS（meta 含 conversationId/sessionId）→ 执行 → ACCEPTED（含 resultState/resultEvidence）
1 任务 = 1 会话，一一对应。
二、根因（必须牢记）
| 现象 | 根因 |
|---|---|
| 工作台任务全卡死、永不执行 | 调度器按 next_run_at 列扫描。工作台直写 SQLite 时若缺/空该列 → 永不拾取（08-31 P2「去掉 next_run_at 用 scheduled_at」是错误判断，09-01 已纠正） |
scheduled_at 写过去时间 → 卡死 |
客户端只对未来 scheduledAt 自动补算 next_run_at；过去/太近时间 → 不补算 → 扫不到 |
| 误以为「调度器停摆」 | 调度器从未停摆（33022 秒级准点执行过）；停摆假象 = next_run_at 没填 |
三、硬规则（实测阈值）
- scheduled_at 必须未来，且留足余量：+60s 稳、+17s 失败（update 往返有几秒延迟，越近越险）
- next_run_at 必须显式写入（工作台链路）：
Date.now() + 5000（+5s 即可，因为这是直写、无补算依赖） - 立即执行参数不存在：argv.json（仅 IDE 渲染）、settings.json（仅插件/sandbox/claw）、无 workbuddy CLI，客户端无并发数/扫描周期配置项 → 无法通过参数控制
- 实际开始时间 = 写库时刻 + 5s（next_run_at）+ 扫描周期（≤30s）≈ 5~35s（工作台按钮链路已是最快路径）
四、并发与排队（09-01 实测）
- 客户端后台自动化并发上限 ≈ 3：同秒触发 5 任务 → 3 个立即并行（各建会话）、2 个排队
- 排队标记：automation_runs.metadata_json 含
queuedPosition（1、2、…） - 并行是任务层面天然支持的，无需任何配置；超出 3 个自动排队
五、automation_runs 状态机
QUEUED（排队, meta.queuedPosition）
→ IN_PROGRESS（建会话, meta.conversationId/sessionId）
→ ACCEPTED（完成, meta.resultState=delivered|side_effect_only|partial_delivered, resultEvidence=assistant_output|external_action|local_file_mutation|none）
另有 PENDING_REVIEW（待人工确认，工作台轮询时显示「待确认」）。
表结构：thread_id / automation_id / status / read_at / thread_title / source_cwd / runs_json / result_success / metadata_json / created_at / updated_at
六、排查命令（Windows / Git Bash）
cd "C:/Users/maidou/.workbuddy"
"D:/miniconda3/python.exe" -c "
import sqlite3
db = sqlite3.connect('workbuddy.db'); db.row_factory = sqlite3.Row
for r in db.execute(\"SELECT id,name,scheduled_at,next_run_at,last_run_at,status FROM automations WHERE deleted_at IS NULL ORDER BY created_at DESC LIMIT 10\"):
print(dict(r))
print('---runs---')
for r in db.execute(\"SELECT automation_id,status,metadata_json FROM automation_runs ORDER BY created_at DESC LIMIT 10\"):
print(dict(r))
"
判定要点：
- 任务有
next_run_at且 < now → 应已被拾取（看 automation_runs） last_run_at仍 None + runs 无记录 → next_run_at 没补算（scheduled_at 太近/过去）- runs 有 QUEUED → 在排队（并发 >3）；有 IN_PROGRESS → 正在跑（看 sessions working）
- 会话：
SELECT id,title,status,created_at FROM sessions WHERE is_background_automation=1
七、服务维护
- 启动：
node server.js（零依赖，端口 8899 自动避让） - 改 server.js 后必须重启才生效（Windows：
taskkill /PID <pid> /F后重启） - 后台运行：
node server.js > /tmp/mcn-workshop.log 2>&1 &