This commit is contained in:
jyong 2025-08-14 15:12:09 +08:00
parent 72ea3b4d01
commit 8b8d257f78

View File

@ -204,7 +204,8 @@ class DatasourceNode(BaseNode):
size=upload_file.size, size=upload_file.size,
storage_key=upload_file.key, 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( yield RunCompletedEvent(
run_result=NodeRunResult( run_result=NodeRunResult(
status=WorkflowNodeExecutionStatus.SUCCEEDED, status=WorkflowNodeExecutionStatus.SUCCEEDED,
@ -525,7 +526,7 @@ class DatasourceNode(BaseNode):
tenant_id=self.tenant_id, tenant_id=self.tenant_id,
) )
if file: if file:
variable_pool.add([self.node_id, "file"], file.to_dict()) variable_pool.add([self.node_id, "file"], file)
yield RunCompletedEvent( yield RunCompletedEvent(
run_result=NodeRunResult( run_result=NodeRunResult(
status=WorkflowNodeExecutionStatus.SUCCEEDED, status=WorkflowNodeExecutionStatus.SUCCEEDED,