File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -11,7 +11,7 @@ use database::{
1111} ;
1212use parking_lot:: RwLock ;
1313use std:: { str:: FromStr , sync:: Arc } ;
14- use tokio:: time:: { self , Duration } ;
14+ use tokio:: time:: { self , Duration , MissedTickBehavior } ;
1515
1616pub fn run_new_queue ( ) -> bool {
1717 std:: env:: var ( "RUN_CRON" )
@@ -372,6 +372,8 @@ async fn cron_enqueue_jobs(ctxt: &SiteCtxt) -> anyhow::Result<()> {
372372/// Entry point for the cron job that manages the benchmark request and job queue.
373373pub async fn cron_main ( site_ctxt : Arc < RwLock < Option < Arc < SiteCtxt > > > > , run_interval : Duration ) {
374374 let mut interval = time:: interval ( run_interval) ;
375+ interval. set_missed_tick_behavior ( MissedTickBehavior :: Delay ) ;
376+
375377 let ctxt = site_ctxt. clone ( ) ;
376378
377379 loop {
You can’t perform that action at this time.
0 commit comments