From 9bf30d8871b2dd959ac4da425d1b32cc87ab75cc Mon Sep 17 00:00:00 2001 From: goulustis Date: Tue, 10 Feb 2026 17:58:23 +0800 Subject: [PATCH] not propagating pipeline_id --- lang_agent/graphs/routing.py | 6 ------ lang_agent/graphs/tool_nodes.py | 6 ------ lang_agent/pipeline.py | 6 ------ 3 files changed, 18 deletions(-) diff --git a/lang_agent/graphs/routing.py b/lang_agent/graphs/routing.py index f3bfa74..a264600 100644 --- a/lang_agent/graphs/routing.py +++ b/lang_agent/graphs/routing.py @@ -91,12 +91,6 @@ class RoutingGraph(GraphBase): tool_manager:ToolManager = self.config.tool_manager_config.setup() self.chat_model = create_agent(self.chat_llm, [], checkpointer=self.memory) - # Propagate pipeline_id and prompt_set_id to tool node config - if self.config.pipeline_id and hasattr(self.config.tool_node_config, 'pipeline_id'): - self.config.tool_node_config.pipeline_id = self.config.pipeline_id - if self.config.prompt_set_id and hasattr(self.config.tool_node_config, 'prompt_set_id'): - self.config.tool_node_config.prompt_set_id = self.config.prompt_set_id - self.tool_node:ToolNodeBase = self.config.tool_node_config.setup(tool_manager=tool_manager, memory=self.memory) diff --git a/lang_agent/graphs/tool_nodes.py b/lang_agent/graphs/tool_nodes.py index 8a5ac30..e412952 100644 --- a/lang_agent/graphs/tool_nodes.py +++ b/lang_agent/graphs/tool_nodes.py @@ -139,12 +139,6 @@ class ChattyToolNode(ToolNodeBase): self.chatty_agent = create_agent(self.chatty_llm, [], checkpointer=self.mem) # self.tool_agent = create_agent(self.tool_llm, self.tool_manager.get_list_langchain_tools(), checkpointer=self.mem) - # Propagate pipeline_id and prompt_set_id to inner tool_node_conf - if self.config.pipeline_id and hasattr(self.config.tool_node_conf, 'pipeline_id'): - self.config.tool_node_conf.pipeline_id = self.config.pipeline_id - if self.config.prompt_set_id and hasattr(self.config.tool_node_conf, 'prompt_set_id'): - self.config.tool_node_conf.prompt_set_id = self.config.prompt_set_id - self.tool_agent = self.config.tool_node_conf.setup(tool_manager=self.tool_manager, memory=self.mem) diff --git a/lang_agent/pipeline.py b/lang_agent/pipeline.py index d5a00b5..bb3e29b 100644 --- a/lang_agent/pipeline.py +++ b/lang_agent/pipeline.py @@ -103,12 +103,6 @@ class Pipeline: self.config.graph_config.base_url = self.config.base_url if self.config.base_url is not None else self.config.graph_config.base_url self.config.graph_config.api_key = self.config.api_key - # Propagate pipeline_id and prompt_set_id to graph config for DB prompt loading - if self.config.pipeline_id is not None and hasattr(self.config.graph_config, 'pipeline_id'): - self.config.graph_config.pipeline_id = self.config.pipeline_id - if self.config.prompt_set_id is not None and hasattr(self.config.graph_config, 'prompt_set_id'): - self.config.graph_config.prompt_set_id = self.config.prompt_set_id - self.graph:GraphBase = self.config.graph_config.setup() def show_graph(self):