From a930b17e2a21e17f37803aedf1dd45e192741c82 Mon Sep 17 00:00:00 2001 From: meteorgan Date: Mon, 27 Jan 2025 20:00:15 +0800 Subject: [PATCH] return content_length for aliyun_drive after writing --- core/src/services/aliyun_drive/writer.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/services/aliyun_drive/writer.rs b/core/src/services/aliyun_drive/writer.rs index 9873eaa73c0..35afaaade7f 100644 --- a/core/src/services/aliyun_drive/writer.rs +++ b/core/src/services/aliyun_drive/writer.rs @@ -115,10 +115,11 @@ impl oio::Write for AliyunDriveWriter { async fn close(&mut self) -> Result { let (Some(upload_id), Some(file_id)) = (self.upload_id.as_ref(), self.file_id.as_ref()) else { - return Ok(Metadata::default()); + return Ok(Metadata::default().with_content_length(self.write_bytes_count)); }; + self.core.complete(file_id, upload_id).await?; - Ok(Metadata::default()) + Ok(Metadata::default().with_content_length(self.write_bytes_count)) } async fn abort(&mut self) -> Result<()> {