From e35deea6d092cfc79b18ad6bdb0a577af3cca105 Mon Sep 17 00:00:00 2001 From: shaohuzhang1 Date: Mon, 5 Jan 2026 18:22:03 +0800 Subject: [PATCH] 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 | 2 +- .../flow/step_node/ai_chat_step_node/impl/base_chat_node.py | 1 + .../step_node/application_node/impl/base_application_node.py | 3 ++- .../flow/step_node/condition_node/impl/base_condition_node.py | 3 ++- .../data_source_local_node/impl/base_data_source_local_node.py | 3 ++- .../data_source_web_node/impl/base_data_source_web_node.py | 3 ++- .../flow/step_node/direct_reply_node/impl/base_reply_node.py | 3 ++- .../document_extract_node/impl/base_document_extract_node.py | 3 ++- .../document_split_node/impl/base_document_split_node.py | 1 + .../flow/step_node/form_node/impl/base_form_node.py | 3 ++- .../image_generate_step_node/impl/base_image_generate_node.py | 1 + .../image_to_video_step_node/impl/base_image_to_video_node.py | 1 + .../impl/base_image_understand_node.py | 3 ++- .../flow/step_node/intent_node/impl/base_intent_node.py | 3 ++- .../knowledge_write_node/impl/base_knowledge_write_node.py | 3 ++- .../step_node/loop_break_node/impl/base_loop_break_node.py | 3 ++- .../loop_continue_node/impl/base_loop_continue_node.py | 3 ++- .../flow/step_node/loop_node/impl/base_loop_node.py | 3 ++- .../flow/step_node/loop_start_node/impl/base_start_node.py | 1 + apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py | 1 + .../impl/base_parameter_extraction_node.py | 3 ++- .../flow/step_node/question_node/impl/base_question_node.py | 3 ++- .../flow/step_node/reranker_node/impl/base_reranker_node.py | 3 ++- .../search_document_node/impl/base_search_document_node.py | 3 ++- .../search_knowledge_node/impl/base_search_knowledge_node.py | 3 ++- .../speech_to_text_step_node/impl/base_speech_to_text_node.py | 1 + .../flow/step_node/start_node/impl/base_start_node.py | 3 ++- .../text_to_speech_step_node/impl/base_text_to_speech_node.py | 1 + .../text_to_video_step_node/impl/base_text_to_video_node.py | 1 + .../flow/step_node/tool_lib_node/impl/base_tool_lib_node.py | 3 ++- .../flow/step_node/tool_node/impl/base_tool_node.py | 3 ++- .../impl/base_variable_aggregation_node.py | 3 ++- .../variable_assign_node/impl/base_variable_assign_node.py | 3 ++- .../impl/base_variable_splitting_node.py | 3 ++- .../impl/base_video_understand_node.py | 3 ++- 35 files changed, 60 insertions(+), 26 deletions(-) diff --git a/apps/application/flow/i_step_node.py b/apps/application/flow/i_step_node.py index 2ae2af6e479..656f578c371 100644 --- a/apps/application/flow/i_step_node.py +++ b/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']) diff --git a/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py b/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py index 47cdff7659b..93b72d41f75 100644 --- a/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py +++ b/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'), diff --git a/apps/application/flow/step_node/application_node/impl/base_application_node.py b/apps/application/flow/step_node/application_node/impl/base_application_node.py index 8a66e6503d5..d59860e7a99 100644 --- a/apps/application/flow/step_node/application_node/impl/base_application_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/condition_node/impl/base_condition_node.py b/apps/application/flow/step_node/condition_node/impl/base_condition_node.py index b1be2fcd5ab..7e5a5e28e35 100644 --- a/apps/application/flow/step_node/condition_node/impl/base_condition_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/data_source_local_node/impl/base_data_source_local_node.py b/apps/application/flow/step_node/data_source_local_node/impl/base_data_source_local_node.py index e1607d9b81c..c2f69b6f21a 100644 --- a/apps/application/flow/step_node/data_source_local_node/impl/base_data_source_local_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py b/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py index cd355b48e3e..8c833a38caa 100644 --- a/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/direct_reply_node/impl/base_reply_node.py b/apps/application/flow/step_node/direct_reply_node/impl/base_reply_node.py index d49e574ba0d..ae366914fa6 100644 --- a/apps/application/flow/step_node/direct_reply_node/impl/base_reply_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/document_extract_node/impl/base_document_extract_node.py b/apps/application/flow/step_node/document_extract_node/impl/base_document_extract_node.py index 5e85d0947b8..15ef1953924 100644 --- a/apps/application/flow/step_node/document_extract_node/impl/base_document_extract_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/document_split_node/impl/base_document_split_node.py b/apps/application/flow/step_node/document_split_node/impl/base_document_split_node.py index 819e10d3b97..aefd4e30480 100644 --- a/apps/application/flow/step_node/document_split_node/impl/base_document_split_node.py +++ b/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', []), } diff --git a/apps/application/flow/step_node/form_node/impl/base_form_node.py b/apps/application/flow/step_node/form_node/impl/base_form_node.py index 86f299561d8..930125124fa 100644 --- a/apps/application/flow/step_node/form_node/impl/base_form_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/image_generate_step_node/impl/base_image_generate_node.py b/apps/application/flow/step_node/image_generate_step_node/impl/base_image_generate_node.py index aefa9ba0be2..f47b1ac41d2 100644 --- a/apps/application/flow/step_node/image_generate_step_node/impl/base_image_generate_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/image_to_video_step_node/impl/base_image_to_video_node.py b/apps/application/flow/step_node/image_to_video_step_node/impl/base_image_to_video_node.py index 5d1ec6f7b10..2bc6a2a02ca 100644 --- a/apps/application/flow/step_node/image_to_video_step_node/impl/base_image_to_video_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/image_understand_step_node/impl/base_image_understand_node.py b/apps/application/flow/step_node/image_understand_step_node/impl/base_image_understand_node.py index 885538d314e..e31cd2f5abe 100644 --- a/apps/application/flow/step_node/image_understand_step_node/impl/base_image_understand_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/intent_node/impl/base_intent_node.py b/apps/application/flow/step_node/intent_node/impl/base_intent_node.py index e829b01f283..2258337855c 100644 --- a/apps/application/flow/step_node/intent_node/impl/base_intent_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/knowledge_write_node/impl/base_knowledge_write_node.py b/apps/application/flow/step_node/knowledge_write_node/impl/base_knowledge_write_node.py index 31124c8797d..165125c7f56 100644 --- a/apps/application/flow/step_node/knowledge_write_node/impl/base_knowledge_write_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/loop_break_node/impl/base_loop_break_node.py b/apps/application/flow/step_node/loop_break_node/impl/base_loop_break_node.py index 103a95b2635..e5e030e75d0 100644 --- a/apps/application/flow/step_node/loop_break_node/impl/base_loop_break_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/loop_continue_node/impl/base_loop_continue_node.py b/apps/application/flow/step_node/loop_continue_node/impl/base_loop_continue_node.py index 2d6f88ae809..d3ee6de636e 100644 --- a/apps/application/flow/step_node/loop_continue_node/impl/base_loop_continue_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/loop_node/impl/base_loop_node.py b/apps/application/flow/step_node/loop_node/impl/base_loop_node.py index 6d08e54776a..2908d3b6f1f 100644 --- a/apps/application/flow/step_node/loop_node/impl/base_loop_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/loop_start_node/impl/base_start_node.py b/apps/application/flow/step_node/loop_start_node/impl/base_start_node.py index e74800ddad9..8058e098b20 100644 --- a/apps/application/flow/step_node/loop_start_node/impl/base_start_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py b/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py index 0b6ffd84801..d463a03648b 100644 --- a/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/parameter_extraction_node/impl/base_parameter_extraction_node.py b/apps/application/flow/step_node/parameter_extraction_node/impl/base_parameter_extraction_node.py index e377e7092c8..0d64c6b1d11 100644 --- a/apps/application/flow/step_node/parameter_extraction_node/impl/base_parameter_extraction_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/question_node/impl/base_question_node.py b/apps/application/flow/step_node/question_node/impl/base_question_node.py index bd40e31dae0..500a6ec3345 100644 --- a/apps/application/flow/step_node/question_node/impl/base_question_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/reranker_node/impl/base_reranker_node.py b/apps/application/flow/step_node/reranker_node/impl/base_reranker_node.py index 28ffda09b7e..70d8ddb69be 100644 --- a/apps/application/flow/step_node/reranker_node/impl/base_reranker_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/search_document_node/impl/base_search_document_node.py b/apps/application/flow/step_node/search_document_node/impl/base_search_document_node.py index ea2edeb6a9b..2bdf43cc0ee 100644 --- a/apps/application/flow/step_node/search_document_node/impl/base_search_document_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/search_knowledge_node/impl/base_search_knowledge_node.py b/apps/application/flow/step_node/search_knowledge_node/impl/base_search_knowledge_node.py index bcc190e6bc1..c9c31327d56 100644 --- a/apps/application/flow/step_node/search_knowledge_node/impl/base_search_knowledge_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/speech_to_text_step_node/impl/base_speech_to_text_node.py b/apps/application/flow/step_node/speech_to_text_step_node/impl/base_speech_to_text_node.py index 722d8ea9fb6..eadd9a1c81d 100644 --- a/apps/application/flow/step_node/speech_to_text_step_node/impl/base_speech_to_text_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/start_node/impl/base_start_node.py b/apps/application/flow/step_node/start_node/impl/base_start_node.py index d56a5a0258d..f1fbf43b729 100644 --- a/apps/application/flow/step_node/start_node/impl/base_start_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/text_to_speech_step_node/impl/base_text_to_speech_node.py b/apps/application/flow/step_node/text_to_speech_step_node/impl/base_text_to_speech_node.py index 12064b51fa6..2a48741ca07 100644 --- a/apps/application/flow/step_node/text_to_speech_step_node/impl/base_text_to_speech_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/text_to_video_step_node/impl/base_text_to_video_node.py b/apps/application/flow/step_node/text_to_video_step_node/impl/base_text_to_video_node.py index ccef0013451..c27ef2642c4 100644 --- a/apps/application/flow/step_node/text_to_video_step_node/impl/base_text_to_video_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/tool_lib_node/impl/base_tool_lib_node.py b/apps/application/flow/step_node/tool_lib_node/impl/base_tool_lib_node.py index b0d1ba28fcf..43014fc0d29 100644 --- a/apps/application/flow/step_node/tool_lib_node/impl/base_tool_lib_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/tool_node/impl/base_tool_node.py b/apps/application/flow/step_node/tool_node/impl/base_tool_node.py index 3ee9e17d948..b6bcbc3f0b1 100644 --- a/apps/application/flow/step_node/tool_node/impl/base_tool_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/variable_aggregation_node/impl/base_variable_aggregation_node.py b/apps/application/flow/step_node/variable_aggregation_node/impl/base_variable_aggregation_node.py index 69c04f0dbd6..e3390dfc2b9 100644 --- a/apps/application/flow/step_node/variable_aggregation_node/impl/base_variable_aggregation_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/variable_assign_node/impl/base_variable_assign_node.py b/apps/application/flow/step_node/variable_assign_node/impl/base_variable_assign_node.py index 6f8138295f9..3ff1982f573 100644 --- a/apps/application/flow/step_node/variable_assign_node/impl/base_variable_assign_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py b/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py index 44d3bf0df3e..447609747e5 100644 --- a/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py +++ b/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'), } diff --git a/apps/application/flow/step_node/video_understand_step_node/impl/base_video_understand_node.py b/apps/application/flow/step_node/video_understand_step_node/impl/base_video_understand_node.py index 90044a54980..3d75d980be1 100644 --- a/apps/application/flow/step_node/video_understand_step_node/impl/base_video_understand_node.py +++ b/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'), }