diff --git a/object_store/src/aws/client.rs b/object_store/src/aws/client.rs index 6307d7f3be7..ae7d3ff465e 100644 --- a/object_store/src/aws/client.rs +++ b/object_store/src/aws/client.rs @@ -686,7 +686,6 @@ impl S3Client { .headers() .get("x-amz-checksum-sha256") .map(|v| v.to_str().unwrap().to_string()); - println!("response={response:#?}"); let content_id = match is_copy { false => get_etag(response.headers()).context(MetadataSnafu)?, diff --git a/object_store/src/aws/mod.rs b/object_store/src/aws/mod.rs index 0ee77d66143..b91d4f0b8a6 100644 --- a/object_store/src/aws/mod.rs +++ b/object_store/src/aws/mod.rs @@ -385,7 +385,7 @@ impl MultipartUpload for S3MultiPartUpload { self.part_idx += 1; let state = Arc::clone(&self.state); Box::pin(async move { - let res = state + let part = state .client .put_part( &state.location, @@ -393,11 +393,7 @@ impl MultipartUpload for S3MultiPartUpload { idx, PutPartPayload::Part(data), ) - .await; - let part = match res { - Ok(part) => part, - Err(e) => Err(e)?, - }; + .await?; state.parts.put(part); Ok(()) }) diff --git a/object_store/src/client/retry.rs b/object_store/src/client/retry.rs index f8731c55e58..601bffdec15 100644 --- a/object_store/src/client/retry.rs +++ b/object_store/src/client/retry.rs @@ -264,7 +264,6 @@ impl RetryableRequest { *request.body_mut() = Some(payload.body()); } - println!("Making request={request:#?}"); match self.client.execute(request).await { Ok(r) => match r.error_for_status_ref() { Ok(_) if r.status().is_success() => {