From 57b391222757f4206d8c06231a3817885459f6d0 Mon Sep 17 00:00:00 2001 From: SSebo Date: Tue, 13 May 2025 13:47:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20common=20prerequisite=20node=20workflow?= =?UTF-8?q?=20remove=20reachable=20node=20that=20failed=20to=20streaming?= =?UTF-8?q?=20llm=E2=80=A6=20(#19552)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: zhangshibo --- api/core/workflow/nodes/answer/base_stream_processor.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/api/core/workflow/nodes/answer/base_stream_processor.py b/api/core/workflow/nodes/answer/base_stream_processor.py index e4f2478890..6671ff0746 100644 --- a/api/core/workflow/nodes/answer/base_stream_processor.py +++ b/api/core/workflow/nodes/answer/base_stream_processor.py @@ -95,7 +95,12 @@ class StreamProcessor(ABC): if node_id not in self.rest_node_ids: return + if node_id in reachable_node_ids: + return + self.rest_node_ids.remove(node_id) + self.rest_node_ids.extend(set(reachable_node_ids) - set(self.rest_node_ids)) + for edge in self.graph.edge_mapping.get(node_id, []): if edge.target_node_id in reachable_node_ids: continue