panyy
/
UnisKB
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: The parameter extraction node does not display input parameters in the execution details (#4239)

v3.2
shaohuzhang1 2025-10-22 18:24:55 +08:00 committed by GitHub
parent c5dfbde07c
commit 7b3c1c7823
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/application/flow/step_node/parameter_extraction_node/impl/base_parameter_extraction_node.py
View File

@ -88,8 +88,10 @@ class BaseParameterExtractionNode(IParameterExtractionNode):
for key, value in details.get('result').items(): for key, value in details.get('result').items():
self.context[key] = value self.context[key] = value
self.context['result'] = details.get('result') 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: 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: if model_params_setting is None:
model_params_setting = get_default_model_params_setting(model_id) model_params_setting = get_default_model_params_setting(model_id)
workspace_id = self.workflow_manage.get_body().get('workspace_id') workspace_id = self.workflow_manage.get_body().get('workspace_id')
@ -106,6 +108,7 @@ class BaseParameterExtractionNode(IParameterExtractionNode):
"index": index, "index": index,
'run_time': self.context.get('run_time'), 'run_time': self.context.get('run_time'),
'type': self.node.type, 'type': self.node.type,
'request': self.context.get('request'),
'result': self.context.get('result'), 'result': self.context.get('result'),
'status': self.status, 'status': self.status,
'err_message': self.err_message 'err_message': self.err_message

3
apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py
View File

@ -36,8 +36,10 @@ class BaseVariableSplittingNode(IVariableSplittingNode):
for key, value in details.get('result').items(): for key, value in details.get('result').items():
self.context[key] = value self.context[key] = value
self.context['result'] = details.get('result') self.context['result'] = details.get('result')
self.context['request'] = details.get('request')
def execute(self, input_variable, variable_list, **kwargs) -> NodeResult: 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} response = {v['field']: smart_jsonpath_search(input_variable, v['expression']) for v in variable_list}
return NodeResult({'result': response, **response}, {}) return NodeResult({'result': response, **response}, {})
@ -47,6 +49,7 @@ class BaseVariableSplittingNode(IVariableSplittingNode):
"index": index, "index": index,
'run_time': self.context.get('run_time'), 'run_time': self.context.get('run_time'),
'type': self.node.type, 'type': self.node.type,
'request': self.context.get('request'),
'result': self.context.get('result'), 'result': self.context.get('result'),
'status': self.status, 'status': self.status,
'err_message': self.err_message 'err_message': self.err_message