File tree Expand file tree Collapse file tree 1 file changed +9
-4
lines changed
Expand file tree Collapse file tree 1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -77,7 +77,7 @@ impl Retry {
7777 loop {
7878 match callback ( ) . await {
7979 Err ( RetryError :: Continue ( e) ) => {
80- self . handle_continue ( e ) ;
80+ self . log ( e , false ) ;
8181 if !self . delay . is_zero ( ) {
8282 tokio:: time:: sleep ( self . delay ) . await ;
8383 }
@@ -97,11 +97,11 @@ impl Retry {
9797 fn handle_err ( & mut self , err : Error ) {
9898 debug_assert ! ( self . retries > 0 ) ;
9999 self . retries -= 1 ;
100- self . handle_continue ( err) ;
100+ self . log ( err, true ) ;
101101 }
102102
103- fn handle_continue ( & mut self , err : Error ) {
104- let _ = sh_warn ! (
103+ fn log ( & self , err : Error , warn : bool ) {
104+ let msg = format ! (
105105 "{msg}{delay} ({retries} tries remaining)" ,
106106 msg = crate :: errors:: display_chain( & err) ,
107107 delay = if self . delay. is_zero( ) {
@@ -111,5 +111,10 @@ impl Retry {
111111 } ,
112112 retries = self . retries,
113113 ) ;
114+ if warn {
115+ let _ = sh_warn ! ( "{msg}" ) ;
116+ } else {
117+ tracing:: info!( "{msg}" ) ;
118+ }
114119 }
115120}
You can’t perform that action at this time.
0 commit comments