Skip to content

Commit c8bace9

Browse files
Apply new retry logic also to re-creating client
1 parent cb9b51f commit c8bace9

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

src/client.rs

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -77,11 +77,16 @@ macro_rules! impl_inner_call {
7777
break;
7878
},
7979
Err(e) => {
80-
warn!("client retry:{}/{} {:?}", errors.len() + 1, $self.config.retry(), e);
81-
errors.push(e);
82-
if errors.len() as u8 == $self.config.retry() {
80+
let failed_attempts = errors.len() + 1;
81+
82+
if retries_exhausted(failed_attempts, $self.config.retry()) {
83+
warn!("re-creating client failed after {} attempts", failed_attempts);
8384
return Err(Error::AllAttemptsErrored(errors));
8485
}
86+
87+
warn!("re-creating client failed with {}, retry: {}/{}", e, failed_attempts, $self.config.retry());
88+
89+
errors.push(e);
8590
}
8691
}
8792
}

0 commit comments

Comments
 (0)