ymq 8bd1b45cba fix: _create_next_task 清除 pm_assigned,防其从 PM 派发任务污染到自动创建的下游任务
根因:PM 派发的 design 任务带 pm_assigned=True,design approved 后 _create_next_task
用 {**params} 继承,导致自动创建的应用脚手架 develop 也带 pm_assigned=True,
被 deploy_test 触发判断(1785 行)误判为「模块级 develop」,跳过 deploy_test,
迭代停在 11 模块 develop approved、永远不部署不测试。

pm_assigned 是「PM 按模块清单派发」标记,只作用于当前任务,下一角色任务由系统
自动创建,必须清除。
2026-08-23 08:54:03 +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%