From 736fbe4ceaed377d312ca5d5a350fbe39d5ecd80 Mon Sep 17 00:00:00 2001 From: Waqar Ahmed Khan Date: Mon, 23 Dec 2024 10:05:03 -0800 Subject: [PATCH] fix upload_id --- aws-s3-transfer-manager/src/operation/upload.rs | 4 ++-- aws-s3-transfer-manager/src/operation/upload/service.rs | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/aws-s3-transfer-manager/src/operation/upload.rs b/aws-s3-transfer-manager/src/operation/upload.rs index fc98693..0021db0 100644 --- a/aws-s3-transfer-manager/src/operation/upload.rs +++ b/aws-s3-transfer-manager/src/operation/upload.rs @@ -161,14 +161,14 @@ async fn try_start_mpu_upload( mpu.upload_id ); let upload_id = mpu.upload_id.clone().expect("upload_id is present"); - let mut mpu_data = MultipartUploadData { upload_part_tasks: Default::default(), read_body_tasks: Default::default(), response: Some(mpu), upload_id: upload_id.clone(), }; - distribute_work(&mut mpu_data, ctx, stream, part_size, upload_id)?; + + distribute_work(&mut mpu_data, ctx, stream, part_size)?; Ok(UploadType::MultipartUpload(mpu_data)) } diff --git a/aws-s3-transfer-manager/src/operation/upload/service.rs b/aws-s3-transfer-manager/src/operation/upload/service.rs index 0113876..10fc24d 100644 --- a/aws-s3-transfer-manager/src/operation/upload/service.rs +++ b/aws-s3-transfer-manager/src/operation/upload/service.rs @@ -101,7 +101,6 @@ pub(super) fn distribute_work( ctx: UploadContext, stream: InputStream, part_size: u64, - upload_id: String, ) -> Result<(), error::Error> { let part_reader = Arc::new( PartReaderBuilder::new() @@ -135,7 +134,7 @@ pub(super) fn distribute_work( let worker = read_body( part_reader.clone(), ctx.clone(), - upload_id.clone(), + mpu_data.upload_id.clone(), svc.clone(), mpu_data.upload_part_tasks.clone(), parent_span_for_upload_tasks.clone(),