File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -324,7 +324,8 @@ fn spawn_job_scheduler() {
324
324
match res. await {
325
325
Err ( err) if err. is_panic ( ) => {
326
326
/* handle panic in above task, re-launching */
327
- tracing:: trace!( "schedule_jobs task died (error={})" , err) ;
327
+ tracing:: error!( "schedule_jobs task died (error={err})" ) ;
328
+ tokio:: time:: sleep ( std:: time:: Duration :: new ( 5 , 0 ) ) . await ;
328
329
}
329
330
_ => unreachable ! ( ) ,
330
331
}
@@ -359,7 +360,8 @@ fn spawn_job_runner(ctx: Arc<Context>) {
359
360
match res. await {
360
361
Err ( err) if err. is_panic ( ) => {
361
362
/* handle panic in above task, re-launching */
362
- tracing:: trace!( "run_scheduled_jobs task died (error={})" , err) ;
363
+ tracing:: error!( "run_scheduled_jobs task died (error={err})" ) ;
364
+ tokio:: time:: sleep ( std:: time:: Duration :: new ( 5 , 0 ) ) . await ;
363
365
}
364
366
_ => unreachable ! ( ) ,
365
367
}
You can’t perform that action at this time.
0 commit comments