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 '

Author: shaohuzhang1

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'),
         }