Skip to content

Commit dff1acd

Browse files
use Debug impl for generic Reqwest errors to provide more info
see https://github.com/apache/arrow-rs/issues/6377 This should help in the interim to identify specific causes of, sometimes confusing, network related errors. I think this change should be temporary until we can find a better way to improve error messages.
1 parent 3293a8c commit dff1acd

File tree

4 files changed

+10
-11
lines changed

4 files changed

+10
-11
lines changed

object_store/src/aws/client.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ pub(crate) enum Error {
8282
message: String,
8383
},
8484

85-
#[snafu(display("Error getting DeleteObjects response body: {}", source))]
85+
#[snafu(display("Error getting DeleteObjects response body: {:?}", source))]
8686
DeleteObjectsResponse { source: reqwest::Error },
8787

8888
#[snafu(display("Got invalid DeleteObjects response: {}", source))]
@@ -93,16 +93,16 @@ pub(crate) enum Error {
9393
#[snafu(display("Error performing list request: {}", source))]
9494
ListRequest { source: crate::client::retry::Error },
9595

96-
#[snafu(display("Error getting list response body: {}", source))]
96+
#[snafu(display("Error getting list response body: {:?}", source))]
9797
ListResponseBody { source: reqwest::Error },
9898

99-
#[snafu(display("Error getting create multipart response body: {}", source))]
99+
#[snafu(display("Error getting create multipart response body: {:?}", source))]
100100
CreateMultipartResponseBody { source: reqwest::Error },
101101

102102
#[snafu(display("Error performing complete multipart request: {}", source))]
103103
CompleteMultipartRequest { source: crate::client::retry::Error },
104104

105-
#[snafu(display("Error getting complete multipart response body: {}", source))]
105+
#[snafu(display("Error getting complete multipart response body: {:?}", source))]
106106
CompleteMultipartResponseBody { source: reqwest::Error },
107107

108108
#[snafu(display("Got invalid list response: {}", source))]

object_store/src/client/retry.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ pub enum Error {
3939
body: Option<String>,
4040
},
4141

42-
#[snafu(display("Error after {retries} retries in {elapsed:?}, max_retries:{max_retries}, retry_timeout:{retry_timeout:?}, source:{source}"))]
42+
#[snafu(display("Error after {retries} retries in {elapsed:?}, max_retries:{max_retries}, retry_timeout:{retry_timeout:?}, source:{source:?}"))]
4343
Reqwest {
4444
retries: usize,
4545
max_retries: usize,
@@ -174,7 +174,6 @@ impl Default for RetryConfig {
174174
backoff: Default::default(),
175175
max_retries: 10,
176176
retry_timeout: Duration::from_secs(3 * 60),
177-
}
178177
}
179178
}
180179

object_store/src/gcp/client.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ enum Error {
5858
#[snafu(display("Error performing list request: {}", source))]
5959
ListRequest { source: crate::client::retry::Error },
6060

61-
#[snafu(display("Error getting list response body: {}", source))]
61+
#[snafu(display("Error getting list response body: {:?}", source))]
6262
ListResponseBody { source: reqwest::Error },
6363

6464
#[snafu(display("Got invalid list response: {}", source))]
@@ -76,7 +76,7 @@ enum Error {
7676
path: String,
7777
},
7878

79-
#[snafu(display("Error getting put response body: {}", source))]
79+
#[snafu(display("Error getting put response body: {:?}", source))]
8080
PutResponseBody { source: reqwest::Error },
8181

8282
#[snafu(display("Got invalid put response: {}", source))]
@@ -93,7 +93,7 @@ enum Error {
9393
#[snafu(display("Error performing complete multipart request: {}", source))]
9494
CompleteMultipartRequest { source: crate::client::retry::Error },
9595

96-
#[snafu(display("Error getting complete multipart response body: {}", source))]
96+
#[snafu(display("Error getting complete multipart response body: {:?}", source))]
9797
CompleteMultipartResponseBody { source: reqwest::Error },
9898

9999
#[snafu(display("Got invalid multipart response: {}", source))]
@@ -102,7 +102,7 @@ enum Error {
102102
#[snafu(display("Error signing blob: {}", source))]
103103
SignBlobRequest { source: crate::client::retry::Error },
104104

105-
#[snafu(display("Got invalid signing blob response: {}", source))]
105+
#[snafu(display("Got invalid signing blob response: {:?}", source))]
106106
InvalidSignBlobResponse { source: reqwest::Error },
107107

108108
#[snafu(display("Got invalid signing blob signature: {}", source))]

object_store/src/http/client.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ enum Error {
4040
#[snafu(display("Request error: {}", source))]
4141
Request { source: retry::Error },
4242

43-
#[snafu(display("Request error: {}", source))]
43+
#[snafu(display("Request error: {:?}", source))]
4444
Reqwest { source: reqwest::Error },
4545

4646
#[snafu(display("Range request not supported by {}", href))]

0 commit comments

Comments
 (0)