yumoqing/pipeline-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: gateway.run_message加generic参数(纯通用模式跳过resolve_project+不装产线能力)

Browse Source
This commit is contained in:
ymq 2026-08-16 18:02:42 +08:00
parent 50c9220d2d
commit 6e61dbbbb9
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pipeline_service/gateway.py
View File

@ -98,7 +98,7 @@ class Gateway:
# ── 统一消息入口 ── # ── 统一消息入口 ──
async def run_message(self, channel: str, user_id: str, content: str, async def run_message(self, channel: str, user_id: str, content: str,
history=None, role: str = "") -> AsyncGenerator[str, None]: history=None, role: str = "", generic: bool = False) -> AsyncGenerator[str, None]:
"""统一消息入口：解析上下文 → 加载产线能力 → AgentExecutor 执行 → yield 事件流。 """统一消息入口：解析上下文 → 加载产线能力 → AgentExecutor 执行 → yield 事件流。
Args: Args:
@ -107,12 +107,16 @@ class Gateway:
content: 用户消息内容 content: 用户消息内容
history: 可选历史消息 history: 可选历史消息
role: 可选产线内角色（驾驶舱 agent 为空） role: 可选产线内角色（驾驶舱 agent 为空）
generic: True = 纯通用会话（不解析项目、不加载产线能力，只用 GENERAL_TOOLS + 通用心智）
""" """
from pipeline_core.agent_config import load_agent_config from pipeline_core.agent_config import load_agent_config
from .agent_loop_v2 import AgentExecutor from .agent_loop_v2 import AgentExecutor
# 1. 解析项目上下文 # 1. 解析项目上下文（纯通用模式跳过，不挂任何产线插件）
ctx = await self.resolve_project(user_id) if generic:
ctx = {"pid": "", "pipeline_id": "", "name": ""}
else:
ctx = await self.resolve_project(user_id)
# 2. 会话生命周期（跟踪 project 切换） # 2. 会话生命周期（跟踪 project 切换）
key = self._session_key(channel, user_id) key = self._session_key(channel, user_id)