pipeline-service

yumoqing/pipeline-service

Fork 0

Commit Graph

Author	SHA1	Message	Date
ymq	bc5ce2f06d	fix: 任务链卡死根治 — 心跳+stale回收+claimed_by僵尸锁清除 - questions.py: agent_ask/answer_question 置 waiting/submitted 时清 claimed_by，否则 poll 器永不重新认领 - agent_loop_v2.py: _t_answer_question 回答后恢复任务 waiting→submitted（此前只标记问题已答，任务永久卡 waiting） - agent_loop.py: _claim_task 加 claimed_by IS NULL 原子认领 + updated_at 心跳；role/pm 循环心跳 COMMIT；pm 认领保持 review 态 - init.py: role poller 回收僵尸 running 任务、pm poller 回收僵尸 review 任务（心跳超时 10 分钟）	2026-08-15 00:11:36 +08:00
yumoqing	4cb406003e	feat(v3.2.0): 主agent+角色agent架构 — role任务认领/问题回路 - pipeline_tasks 增加 role/claimed_by 字段+索引（存量库需ALTER） - agent_loop 重写为角色循环：原子认领(role匹配+令牌校验)→LLM执行→交付/need_info提问 - 角色别名归一化(developer→develop等)，ROLE_PROMPT改replace防花括号崩溃 - questions.py 新增问题回路：agent_ask/answer_question/forward_question/list_questions - init.py 注册 pipeline_role_submit 与问题回路 env 接口	2026-08-05 12:58:52 +08:00

Author

SHA1

Message

Date

ymq

bc5ce2f06d

fix: 任务链卡死根治 — 心跳+stale回收+claimed_by僵尸锁清除

- questions.py: agent_ask/answer_question 置 waiting/submitted 时清 claimed_by，否则 poll 器永不重新认领
- agent_loop_v2.py: _t_answer_question 回答后恢复任务 waiting→submitted（此前只标记问题已答，任务永久卡 waiting）
- agent_loop.py: _claim_task 加 claimed_by IS NULL 原子认领 + updated_at 心跳；role/pm 循环心跳 COMMIT；pm 认领保持 review 态
- init.py: role poller 回收僵尸 running 任务、pm poller 回收僵尸 review 任务（心跳超时 10 分钟）

2026-08-15 00:11:36 +08:00

yumoqing

4cb406003e

feat(v3.2.0): 主agent+角色agent架构 — role任务认领/问题回路

- pipeline_tasks 增加 role/claimed_by 字段+索引（存量库需ALTER）
- agent_loop 重写为角色循环：原子认领(role匹配+令牌校验)→LLM执行→交付/need_info提问
- 角色别名归一化(developer→develop等)，ROLE_PROMPT改replace防花括号崩溃
- questions.py 新增问题回路：agent_ask/answer_question/forward_question/list_questions
- init.py 注册 pipeline_role_submit 与问题回路 env 接口

2026-08-05 12:58:52 +08:00

2 Commits