fix: The AI dialogue node in the workflow has an abnormal branch. After successfully writing to the knowledge base through the abnormal branch, the execution record status is' failed '

apps/application/flow/i_step_node.py

@@ -129,7 +129,7 @@ def get_workflow_state(workflow):
     details = workflow.get_runtime_details()
     node_list = details.values()
     all_node = [*node_list, *get_loop_workflow_node(node_list)]
-    err = any([True for value in all_node if value.get('status') == 500])
+    err = any([True for value in all_node if value.get('status') == 500 and not value.get('enableException')])
     if err:
         return State.FAILURE
     write_is_exist = any([True for value in all_node if value.get('type') == 'knowledge-write-node'])

apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py

@@ -332,6 +332,7 @@ def get_details(self, index: int, **kwargs):
             'question': self.context.get('question'),
             'answer': self.context.get('answer'),
             'reasoning_content': self.context.get('reasoning_content'),
+            'enableException': self.node.properties.get('enableException'),
             'type': self.node.type,
             'message_tokens': self.context.get('message_tokens'),
             'answer_tokens': self.context.get('answer_tokens'),

apps/application/flow/step_node/application_node/impl/base_application_node.py

@@ -287,5 +287,6 @@ def get_details(self, index: int, **kwargs):
             'image_list': self.workflow_manage.image_list,
             'audio_list': self.workflow_manage.audio_list,
             'video_list': self.workflow_manage.video_list,
-            'application_node_dict': self.context.get('application_node_dict')
+            'application_node_dict': self.context.get('application_node_dict'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/condition_node/impl/base_condition_node.py

@@ -59,5 +59,6 @@ def get_details(self, index: int, **kwargs):
             'branch_name': self.context.get('branch_name'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/data_source_local_node/impl/base_data_source_local_node.py

@@ -47,5 +47,6 @@ def get_details(self, index: int, **kwargs):
             'file_list': self.context.get('file_list'),
             'knowledge_base': self.workflow_params.get('knowledge_base'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py

@@ -93,5 +93,6 @@ def get_details(self, index: int, **kwargs):
             'output_params': self.context.get('document_list'),
             'knowledge_base': self.workflow_params.get('knowledge_base'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/direct_reply_node/impl/base_reply_node.py

@@ -42,5 +42,6 @@ def get_details(self, index: int, **kwargs):
             'type': self.node.type,
             'answer': self.context.get('answer'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/document_extract_node/impl/base_document_extract_node.py

@@ -85,5 +85,6 @@ def get_details(self, index: int, **kwargs):
             'content': [file_content[:500] for file_content in content],
             'status': self.status,
             'err_message': self.err_message,
-            'document_list': self.context.get('document_list')
+            'document_list': self.context.get('document_list'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/document_split_node/impl/base_document_split_node.py

@@ -187,5 +187,6 @@ def get_details(self, index: int, **kwargs):
             'with_filter': self.context.get('with_filter'),
             'patterns': self.context.get('patterns'),
             'split_strategy': self.context.get('split_strategy'),
+            'enableException': self.node.properties.get('enableException'),
             # 'document_list': self.context.get('document_list', []),
         }

apps/application/flow/step_node/form_node/impl/base_form_node.py

@@ -173,5 +173,6 @@ def get_details(self, index: int, **kwargs):
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/image_generate_step_node/impl/base_image_generate_node.py

@@ -155,4 +155,5 @@ def get_details(self, index: int, **kwargs):
             'image_list': self.context.get('image_list'),
             'dialogue_type': self.context.get('dialogue_type'),
             'negative_prompt': self.context.get('negative_prompt'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/image_to_video_step_node/impl/base_image_to_video_node.py

@@ -182,4 +182,5 @@ def get_details(self, index: int, **kwargs):
             'last_frame_url': self.context.get('last_frame_url'),
             'dialogue_type': self.context.get('dialogue_type'),
             'negative_prompt': self.context.get('negative_prompt'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/image_understand_step_node/impl/base_image_understand_node.py

@@ -254,5 +254,6 @@ def get_details(self, index: int, **kwargs):
             'status': self.status,
             'err_message': self.err_message,
             'image_list': self.context.get('image_list'),
-            'dialogue_type': self.context.get('dialogue_type')
+            'dialogue_type': self.context.get('dialogue_type'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/intent_node/impl/base_intent_node.py

@@ -249,5 +249,6 @@ def get_details(self, index: int, **kwargs):
             'message_tokens': self.context.get('message_tokens'),
             'answer_tokens': self.context.get('answer_tokens'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/knowledge_write_node/impl/base_knowledge_write_node.py

@@ -325,5 +325,6 @@ def get_details(self, index: int, **kwargs):
             'type': self.node.type,
             'write_content': self.context.get("write_content"),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/loop_break_node/impl/base_loop_break_node.py

@@ -58,5 +58,6 @@ def get_details(self, index: int, **kwargs):
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/loop_continue_node/impl/base_loop_continue_node.py

@@ -48,5 +48,6 @@ def get_details(self, index: int, **kwargs):
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/loop_node/impl/base_loop_node.py

@@ -303,5 +303,6 @@ def get_details(self, index: int, **kwargs):
             'loop_context_data': self.get_loop_context_data(),
             'loop_node_data': self.context.get("loop_node_data"),
             'loop_answer_data': self.context.get("loop_answer_data"),
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/loop_start_node/impl/base_start_node.py

@@ -55,4 +55,5 @@ def get_details(self, index: int, **kwargs):
             'type': self.node.type,
             'status': self.status,
             'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py

@@ -73,4 +73,5 @@ def get_details(self, index: int, **kwargs):
             'mcp_tool': self.context.get('mcp_tool'),
             'tool_params': self.context.get('tool_params'),
             'result': self.context.get('result'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/parameter_extraction_node/impl/base_parameter_extraction_node.py

@@ -113,5 +113,6 @@ def get_details(self, index: int, **kwargs):
             'request': self.context.get('request'),
             'result': self.context.get('result'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/question_node/impl/base_question_node.py

@@ -156,5 +156,6 @@ def get_details(self, index: int, **kwargs):
             'message_tokens': self.context.get('message_tokens'),
             'answer_tokens': self.context.get('answer_tokens'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/reranker_node/impl/base_reranker_node.py

@@ -122,5 +122,6 @@ def get_details(self, index: int, **kwargs):
             'result_list': self.context.get('result_list'),
             'result': self.context.get('result'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/search_document_node/impl/base_search_document_node.py

@@ -200,5 +200,6 @@ def get_details(self, index: int, **kwargs):
             'knowledge_items': self.context.get('knowledge_items'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/search_knowledge_node/impl/base_search_knowledge_node.py

@@ -180,5 +180,6 @@ def get_details(self, index: int, **kwargs):
             'paragraph_list': self.context.get('paragraph_list'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/speech_to_text_step_node/impl/base_speech_to_text_node.py

@@ -70,4 +70,5 @@ def get_details(self, index: int, **kwargs):
             'status': self.status,
             'err_message': self.err_message,
             'audio_list': self.context.get('audio_list'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/start_node/impl/base_start_node.py

@@ -106,5 +106,6 @@ def get_details(self, index: int, **kwargs):
             'document_list': self.context.get('document'),
             'audio_list': self.context.get('audio'),
             'other_list': self.context.get('other'),
-            'global_fields': global_fields
+            'global_fields': global_fields,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/text_to_speech_step_node/impl/base_text_to_speech_node.py

@@ -144,4 +144,5 @@ def get_details(self, index: int, **kwargs):
             'content': self.context.get('content'),
             'err_message': self.err_message,
             'answer': self.context.get('answer'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/text_to_video_step_node/impl/base_text_to_video_node.py

@@ -155,4 +155,5 @@ def get_details(self, index: int, **kwargs):
             'image_list': self.context.get('image_list'),
             'dialogue_type': self.context.get('dialogue_type'),
             'negative_prompt': self.context.get('negative_prompt'),
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/tool_lib_node/impl/base_tool_lib_node.py

@@ -258,5 +258,6 @@ def get_details(self, index: int, **kwargs):
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/tool_node/impl/base_tool_node.py

@@ -130,5 +130,6 @@ def get_details(self, index: int, **kwargs):
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/variable_aggregation_node/impl/base_variable_aggregation_node.py

@@ -85,5 +85,6 @@ def get_details(self, index: int, **kwargs):
             'strategy': self.context.get('strategy'),
             'group_list': group_list,
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/variable_assign_node/impl/base_variable_assign_node.py

@@ -100,5 +100,6 @@ def get_details(self, index: int, **kwargs):
             'variable_list': self.context.get('variable_list'),
             'result_list': self.context.get('result_list'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py

@@ -53,5 +53,6 @@ def get_details(self, index: int, **kwargs):
             'request': self.context.get('request'),
             'result': self.context.get('result'),
             'status': self.status,
-            'err_message': self.err_message
+            'err_message': self.err_message,
+            'enableException': self.node.properties.get('enableException'),
         }

apps/application/flow/step_node/video_understand_step_node/impl/base_video_understand_node.py

@@ -246,5 +246,6 @@ def get_details(self, index: int, **kwargs):
             'status': self.status,
             'err_message': self.err_message,
             'video_list': self.context.get('video_list'),
-            'dialogue_type': self.context.get('dialogue_type')
+            'dialogue_type': self.context.get('dialogue_type'),
+            'enableException': self.node.properties.get('enableException'),
         }