Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
avantgardnerio committed Nov 26, 2024
1 parent 6483642 commit 5537c29
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 8 deletions.
1 change: 0 additions & 1 deletion object_store/src/aws/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)?,
Expand Down
8 changes: 2 additions & 6 deletions object_store/src/aws/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -385,19 +385,15 @@ 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,
&state.upload_id,
idx,
PutPartPayload::Part(data),
)
.await;
let part = match res {
Ok(part) => part,
Err(e) => Err(e)?,
};
.await?;
state.parts.put(part);
Ok(())
})
Expand Down
1 change: 0 additions & 1 deletion object_store/src/client/retry.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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() => {
Expand Down

0 comments on commit 5537c29

Please sign in to comment.