From 9c6bf019c8a69b4baaba1d9221c354b5dfa2b4a6 Mon Sep 17 00:00:00 2001 From: shaohuzhang1 <80892890+shaohuzhang1@users.noreply.github.com> Date: Wed, 22 Oct 2025 17:10:27 +0800 Subject: [PATCH] fix: Variable splitting and parameter extraction result in data loss when there is a form collection node (#4236) --- .../impl/base_parameter_extraction_node.py | 2 +- .../impl/base_variable_splitting_node.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 fa950cf0a..f8a81a9f1 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 @@ -86,7 +86,7 @@ class BaseParameterExtractionNode(IParameterExtractionNode): def save_context(self, details, workflow_manage): for key, value in details.get('result').items(): - self.context['key'] = value + self.context[key] = value self.context['result'] = details.get('result') def execute(self, input_variable, variable_list, model_params_setting, model_id, **kwargs) -> NodeResult: 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 0d2cc964c..a13764467 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 @@ -34,7 +34,7 @@ def smart_jsonpath_search(data: dict, path: str): class BaseVariableSplittingNode(IVariableSplittingNode): def save_context(self, details, workflow_manage): for key, value in details.get('result').items(): - self.context['key'] = value + self.context[key] = value self.context['result'] = details.get('result') def execute(self, input_variable, variable_list, **kwargs) -> NodeResult: