Skip to content

Commit fadd6a6

Browse files
authored
fix: Loop internal node error did not terminate workflow (#4520)
1 parent f048b5a commit fadd6a6

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

apps/application/flow/workflow_manage.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -471,6 +471,8 @@ def hand_event_node_result(self, current_node, node_result_future):
471471
current_node.node_chunk.add_chunk(chunk)
472472
else:
473473
list(result)
474+
if current_node.status == 500:
475+
return None
474476
return current_result
475477
except Exception as e:
476478
# 添加节点

0 commit comments

Comments
 (0)