ymq 8d3dd7c980 fix: 回退任务链 pm_assigned 污染 + 模块级判断改 previous_role + start_fix 放宽 open
三处根因修复(hrs6 回退重做任务 approve 后链断的完整根因链):

1. _rollback_task_chain 创建回退任务时 new_params.pop('pm_assigned'):
   回退重做任务继承 target_task 的 pm_assigned=True,approve 后命中
   「模块级 develop 跳过 deploy_test」分支,任务链断在 approved。
   与 _create_next_task 的 pop 对齐(两处同源,回退路径漏了)。

2. 模块级 develop 判断从 pm_assigned 改为 previous_role 为空:
   pm_assigned 会被 design 任务污染(design 也是 PM create_tasks 派发、
   带 pm_assigned=True,派生的应用级 develop 继承后被误判模块级)。
   previous_role 才是可靠信号:模块级(PM 直接派发)= 空,
   应用级(design 派生/回退重做)= agent.design。

3. start_fix 放宽 from 状态 [confirmed] → [confirmed, open]:
   PM review_rollback 回退 develop 时不走 confirm_bug,bug 停在 open,
   start_fix 只认 confirmed 导致 develop 修完代码无法 fix_bug,
   bug 永远 open、闭环断在 fixed 环节。
2026-08-23 14:48:14 +08:00
2026-08-08 11:43:26 +08:00

pipeline_service

产线执行引擎 —— 任务调度、步骤执行、人工任务交互、LLM 桥接。

功能

  • 任务执行DAG 步骤调度与状态机
  • 人工任务:审批/输入等待与交互
  • LLM 桥接:统一 LLM 调用接口
  • Agent LoopAI Agent 多轮任务执行
  • 意图分类:自然语言意图识别
  • 产物管理:步骤输入输出存储

数据表

说明
pipeline_tasks 任务实例
pipeline_task_steps 步骤执行记录
pipeline_artifacts 步骤产物
pipeline_human_tasks 人工任务
pipeline_step_types 步骤类型注册

安装

cd pkgs/pipeline-service && pip install .

核心模块

文件 职责
executor.py 任务/步骤调度引擎
storage.py 数据库读写
llm_bridge.py LLM API 调用
agent_loop.py AI Agent 多轮执行
human.py 人工任务处理
intent_classifier.py 意图识别
state.py 状态机
step_registry.py 步骤类型注册表
Description
No description provided
Readme 1.4 MiB
Languages
Python 99.5%
Shell 0.5%