(arrow-rs) branch master updated: refactor: log server error during object store retries (#5294)

[mneumann]

This is an automated email from the ASF dual-hosted git repository.

mneumann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git


The following commit(s) were added to refs/heads/master by this push:
     new fcfe36fa2c refactor: log server error during object store retries 
(#5294)
fcfe36fa2c is described below

commit fcfe36fa2cc5d83db756f988210dfe587b77d06c
Author: Marco Neumann <ma...@crepererum.net>
AuthorDate: Thu Jan 11 11:43:09 2024 +0100

    refactor: log server error during object store retries (#5294)
    
    Similar to transport errors, log the server error as well. That should
    help debugging.
---
 object_store/src/client/retry.rs | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git a/object_store/src/client/retry.rs b/object_store/src/client/retry.rs
index 9d21867d8a..fbd3645d27 100644
--- a/object_store/src/client/retry.rs
+++ b/object_store/src/client/retry.rs
@@ -246,7 +246,13 @@ impl RetryExt for reqwest::RequestBuilder {
 
                             let sleep = backoff.next();
                             retries += 1;
-                            info!("Encountered server error, backing off for 
{} seconds, retry {} of {}", sleep.as_secs_f32(), retries, max_retries);
+                            info!(
+                                "Encountered server error, backing off for {} 
seconds, retry {} of {}: {}",
+                                sleep.as_secs_f32(),
+                                retries,
+                                max_retries,
+                                e,
+                            );
                             tokio::time::sleep(sleep).await;
                         }
                     },
@@ -277,7 +283,13 @@ impl RetryExt for reqwest::RequestBuilder {
                         }
                         let sleep = backoff.next();
                         retries += 1;
-                        info!("Encountered transport error ({}) backing off 
for {} seconds, retry {} of {}", e, sleep.as_secs_f32(), retries, max_retries);
+                        info!(
+                            "Encountered transport error backing off for {} 
seconds, retry {} of {}: {}", 
+                            sleep.as_secs_f32(),
+                            retries,
+                            max_retries,
+                            e,
+                        );
                         tokio::time::sleep(sleep).await;
                     }
                 }