diff --git a/block-streamer/src/lake_s3_client.rs b/block-streamer/src/lake_s3_client.rs index 9e1afff0..fc92c8f2 100644 --- a/block-streamer/src/lake_s3_client.rs +++ b/block-streamer/src/lake_s3_client.rs @@ -144,12 +144,12 @@ impl LakeS3Client { let prefix = prefix.to_owned(); async move { - metrics::LAKE_S3_GET_REQUEST_COUNT.inc(); - let object = s3_client.get_object(&bucket, &prefix).await?; let bytes = object.body.collect().await?.into_bytes().to_vec(); + metrics::LAKE_S3_GET_REQUEST_COUNT.inc(); + Ok(bytes) } .boxed()