From 8b8d257f7860c4c761e1b23dffdc4a52fb8f4f7f Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Thu, 14 Aug 2025 15:12:09 +0800 Subject: [PATCH] fix file --- api/core/workflow/nodes/datasource/datasource_node.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/api/core/workflow/nodes/datasource/datasource_node.py b/api/core/workflow/nodes/datasource/datasource_node.py index dca523de81..a24ff4d98a 100644 --- a/api/core/workflow/nodes/datasource/datasource_node.py +++ b/api/core/workflow/nodes/datasource/datasource_node.py @@ -204,7 +204,8 @@ class DatasourceNode(BaseNode): size=upload_file.size, storage_key=upload_file.key, ) - variable_pool.add([self.node_id, "file"], file_info.to_dict()) + variable_pool.add([self.node_id, "file"], file_info) + #variable_pool.add([self.node_id, "file"], file_info.to_dict()) yield RunCompletedEvent( run_result=NodeRunResult( status=WorkflowNodeExecutionStatus.SUCCEEDED, @@ -525,7 +526,7 @@ class DatasourceNode(BaseNode): tenant_id=self.tenant_id, ) if file: - variable_pool.add([self.node_id, "file"], file.to_dict()) + variable_pool.add([self.node_id, "file"], file) yield RunCompletedEvent( run_result=NodeRunResult( status=WorkflowNodeExecutionStatus.SUCCEEDED,