From 7b3c1c782388903b29d4cb7f18490dea1f2c5950 Mon Sep 17 00:00:00 2001
From: shaohuzhang1 <80892890+shaohuzhang1@users.noreply.github.com>
Date: Wed, 22 Oct 2025 18:24:55 +0800
Subject: [PATCH] fix: The parameter extraction node does not display input
 parameters in the execution details (#4239)

---
 .../impl/base_parameter_extraction_node.py                     | 3 +++
 .../impl/base_variable_splitting_node.py                       | 3 +++
 2 files changed, 6 insertions(+)

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 aff510028..04c6b0ca1 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
@@ -88,8 +88,10 @@ class BaseParameterExtractionNode(IParameterExtractionNode):
         for key, value in details.get('result').items():
             self.context[key] = value
         self.context['result'] = details.get('result')
+        self.context['request'] = details.get('request')
 
     def execute(self, input_variable, variable_list, model_params_setting, model_id, **kwargs) -> NodeResult:
+        self.context['request'] = input_variable
         if model_params_setting is None:
             model_params_setting = get_default_model_params_setting(model_id)
         workspace_id = self.workflow_manage.get_body().get('workspace_id')
@@ -106,6 +108,7 @@ class BaseParameterExtractionNode(IParameterExtractionNode):
             "index": index,
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
+            'request': self.context.get('request'),
             'result': self.context.get('result'),
             'status': self.status,
             'err_message': self.err_message
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 a13764467..981e161ed 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
@@ -36,8 +36,10 @@ class BaseVariableSplittingNode(IVariableSplittingNode):
         for key, value in details.get('result').items():
             self.context[key] = value
         self.context['result'] = details.get('result')
+        self.context['request'] = details.get('request')
 
     def execute(self, input_variable, variable_list, **kwargs) -> NodeResult:
+        self.context['request'] = input_variable
         response = {v['field']: smart_jsonpath_search(input_variable, v['expression']) for v in variable_list}
         return NodeResult({'result': response, **response}, {})
 
@@ -47,6 +49,7 @@ class BaseVariableSplittingNode(IVariableSplittingNode):
             "index": index,
             'run_time': self.context.get('run_time'),
             'type': self.node.type,
+            'request': self.context.get('request'),
             'result': self.context.get('result'),
             'status': self.status,
             'err_message': self.err_message