From ac6b636c238da97c4cc90d9e4fd6d378f1c19bff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E8=89=AF?= <841369634@qq.com> Date: Tue, 12 May 2026 10:53:04 +0800 Subject: [PATCH] fix: Fix the issue of null pointer exception when get reference content --- .../flow/step_node/ai_chat_step_node/impl/base_chat_node.py | 2 +- .../flow/step_node/direct_reply_node/impl/base_reply_node.py | 2 +- .../document_split_node/impl/base_document_split_node.py | 2 +- apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py | 2 +- .../search_document_node/impl/base_search_document_node.py | 2 +- .../search_knowledge_node/impl/base_search_knowledge_node.py | 2 +- .../variable_assign_node/impl/base_variable_assign_node.py | 2 +- 7 files changed, 7 insertions(+), 7 deletions(-) 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 cdd8a5f0af8..89c2d6acb66 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 @@ -375,7 +375,7 @@ def handle_variables(self, tool_params): def get_reference_content(self, fields: List[str]): return str(self.workflow_manage.get_reference_field( fields[0], - fields[1:])) + fields[1:])) if fields else '' @staticmethod def get_history_message(history_chat_record, dialogue_number, dialogue_type, runtime_node_id): 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 ae366914fa6..e70c45afd07 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 @@ -32,7 +32,7 @@ def generate_reply_content(self, prompt): def get_reference_content(self, fields: List[str]): return str(self.workflow_manage.get_reference_field( fields[0], - fields[1:])) + fields[1:])) if fields else '' def get_details(self, index: int, **kwargs): return { 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 aefd4e30480..5e71cdd50a1 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 @@ -42,7 +42,7 @@ def save_context(self, details, workflow_manage): self.context['exception_message'] = details.get('err_message') def get_reference_content(self, fields: List[str]): - return self.workflow_manage.get_reference_field(fields[0], fields[1:]) + return self.workflow_manage.get_reference_field(fields[0], fields[1:]) if fields else None def execute(self, document_list, knowledge_id, split_strategy, paragraph_title_relate_problem_type, paragraph_title_relate_problem, paragraph_title_relate_problem_reference, 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 bf236e51763..82dd8a8a545 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 @@ -60,7 +60,7 @@ def handle_variables(self, tool_params): def get_reference_content(self, fields: List[str]): return self.workflow_manage.get_reference_field( fields[0], - fields[1:]) + fields[1:]) if fields else None def get_details(self, index: int, **kwargs): return { 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 baadd10ac40..1d85cff5331 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 @@ -24,7 +24,7 @@ def save_context(self, details, workflow_manage): self.context['exception_message'] = details.get('err_message') def get_reference_content(self, fields: List[str]): - return self.workflow_manage.get_reference_field(fields[0], fields[1:]) + return self.workflow_manage.get_reference_field(fields[0], fields[1:]) if fields else None def execute(self, knowledge_id_list: List, search_mode: str, search_scope_type: str, search_scope_source: str, search_scope_reference: List, question_reference: List, search_condition_type: str, 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 adac9866d8c..35a6fbd19b3 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 @@ -71,7 +71,7 @@ def save_context(self, details, workflow_manage): self.context['exception_message'] = details.get('err_message') def get_reference_content(self, fields: List[str]): - return self.workflow_manage.get_reference_field(fields[0], fields[1:]) + return self.workflow_manage.get_reference_field(fields[0], fields[1:]) if fields else None def execute(self, knowledge_id_list, knowledge_setting, question, show_knowledge, search_scope_type, search_scope_source, 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 9cadb82e5f3..b9572805acf 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 @@ -109,7 +109,7 @@ def execute(self, variable_list, **kwargs) -> NodeResult: def get_reference_content(self, fields: List[str]): return self.workflow_manage.get_reference_field( fields[0], - fields[1:]) + fields[1:]) if fields else None def get_details(self, index: int, **kwargs): return {