From 6e61dbbbb9f0135bc0dc15e2b57e7891a064c20b Mon Sep 17 00:00:00 2001 From: ymq Date: Sun, 16 Aug 2026 18:02:42 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20gateway.run=5Fmessage=E5=8A=A0generic?= =?UTF-8?q?=E5=8F=82=E6=95=B0(=E7=BA=AF=E9=80=9A=E7=94=A8=E6=A8=A1?= =?UTF-8?q?=E5=BC=8F=E8=B7=B3=E8=BF=87resolve=5Fproject+=E4=B8=8D=E8=A3=85?= =?UTF-8?q?=E4=BA=A7=E7=BA=BF=E8=83=BD=E5=8A=9B)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pipeline_service/gateway.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/pipeline_service/gateway.py b/pipeline_service/gateway.py index b65e561..7735318 100644 --- a/pipeline_service/gateway.py +++ b/pipeline_service/gateway.py @@ -98,7 +98,7 @@ class Gateway: # ── 统一消息入口 ── 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 事件流。 Args: @@ -107,12 +107,16 @@ class Gateway: content: 用户消息内容 history: 可选历史消息 role: 可选产线内角色（驾驶舱 agent 为空） + generic: True = 纯通用会话（不解析项目、不加载产线能力，只用 GENERAL_TOOLS + 通用心智） """ from pipeline_core.agent_config import load_agent_config from .agent_loop_v2 import AgentExecutor - # 1. 解析项目上下文 - ctx = await self.resolve_project(user_id) + # 1. 解析项目上下文（纯通用模式跳过，不挂任何产线插件） + if generic: + ctx = {"pid": "", "pipeline_id": "", "name": ""} + else: + ctx = await self.resolve_project(user_id) # 2. 会话生命周期（跟踪 project 切换） key = self._session_key(channel, user_id)