From 773b1f8d5c39f49ffa8d1636efeec76fc333c2e8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E8=89=AF?= <841369634@qq.com>
Date: Mon, 20 Jul 2026 13:50:58 +0800
Subject: [PATCH] pref: Change recursion to loop to avoid stack overflow

---
 apps/application/flow/workflow_manage.py | 45 ++++++++++++------------
 1 file changed, 23 insertions(+), 22 deletions(-)

diff --git a/apps/application/flow/workflow_manage.py b/apps/application/flow/workflow_manage.py
index f1323c6d4b7..9c4f12a4957 100644
--- a/apps/application/flow/workflow_manage.py
+++ b/apps/application/flow/workflow_manage.py
@@ -65,28 +65,29 @@ def contains(self, node_chunk):
         return self.node_chunk_list.__contains__(node_chunk)
 
     def pop(self):
-        if self.current_node_chunk is None:
-            try:
-                current_node_chunk = self.node_chunk_list.pop(0)
-                self.current_node_chunk = current_node_chunk
-            except IndexError as e:
-                pass
-        if self.current_node_chunk is not None:
-            try:
-                chunk = self.current_node_chunk.chunk_list.pop(0)
-                return chunk
-            except IndexError as e:
-                if self.current_node_chunk.is_end():
-                    self.current_node_chunk = None
-                    if self.work_flow.answer_is_not_empty():
-                        chunk = self.work_flow.base_to_response.to_stream_chunk_response(
-                            self.work_flow.params['chat_id'],
-                            self.work_flow.params['chat_record_id'],
-                            '\n\n', False, 0, 0)
-                        self.work_flow.append_answer('\n\n')
-                        return chunk
-                    return self.pop()
-        return None
+        while True:
+            if self.current_node_chunk is None:
+                try:
+                    current_node_chunk = self.node_chunk_list.pop(0)
+                    self.current_node_chunk = current_node_chunk
+                except IndexError as e:
+                    pass
+            if self.current_node_chunk is not None:
+                try:
+                    chunk = self.current_node_chunk.chunk_list.pop(0)
+                    return chunk
+                except IndexError as e:
+                    if self.current_node_chunk.is_end():
+                        self.current_node_chunk = None
+                        if self.work_flow.answer_is_not_empty():
+                            chunk = self.work_flow.base_to_response.to_stream_chunk_response(
+                                self.work_flow.params['chat_id'],
+                                self.work_flow.params['chat_record_id'],
+                                '\n\n', False, 0, 0)
+                            self.work_flow.append_answer('\n\n')
+                            return chunk
+                        continue
+            return None
 
 
 class WorkflowManage: