15308555518/ MaxKB
1
0
Fork 0
mirror of https://github.com/1Panel-dev/MaxKB.git synced 2025-12-26 01:33:05 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix: The data source tool cannot obtain the execution parameters (#4517)

This commit is contained in:
shaohuzhang1 2025-12-15 18:22:16 +08:00 committed by GitHub
parent 067cd73325
commit 7c48a6cec0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/application/flow/step_node/tool_lib_node/impl/base_tool_lib_node.py
View File

@ -197,16 +197,18 @@ class BaseToolLibNodeNode(IToolLibNode):
else:
all_params = init_params_default_value | params
if self.node.properties.get('kind') == 'data-source':
exist = function_executor.exec_code(f'{tool_lib.code}\ndef function_exist(function_name): return callable(globals().get(function_name))', {'function_name': 'get_download_file_list'})
exist = function_executor.exec_code(
f'{tool_lib.code}\ndef function_exist(function_name): return callable(globals().get(function_name))',
{'function_name': 'get_download_file_list'})
all_params = {**all_params, **self.workflow_params.get('data_source')}
if exist:
download_file_list = []
download_list = function_executor.exec_code(tool_lib.code,
{**all_params, **self.workflow_params.get('data_source')},
all_params,
function_name='get_download_file_list')
for item in download_list:
result = function_executor.exec_code(tool_lib.code,
{**all_params, **self.workflow_params.get('data_source'),
'download_item': item},
{**all_params, 'download_item': item},
function_name='download')
file_bytes = result.get('file_bytes', [])
chunks = []