diff --git a/src/main.rs b/src/main.rs index e2b7416..099c0cc 100644 --- a/src/main.rs +++ b/src/main.rs @@ -91,25 +91,25 @@ async fn main() -> Result<(), Box> { sched.clone(), api_config.clone(), )?; - member_scheduler.queue().await; + member_scheduler.queue().await?; let balance_scheduler = schedulers::balance::scheduler::Scheduler::get_instance( pool.clone(), sched.clone(), api_config.clone(), )?; - balance_scheduler.queue().await; + balance_scheduler.queue().await?; let vendor_scheduler = schedulers::vendor::scheduler::Scheduler::get_instance( pool.clone(), sched.clone(), api_config.clone(), )?; - vendor_scheduler.queue().await; + vendor_scheduler.queue().await?; let game_scheduler = schedulers::game::scheduler::Scheduler::get_instance( pool.clone(), sched.clone(), api_config.clone(), )?; - game_scheduler.queue().await; + game_scheduler.queue().await?; let _h_scheduler = sched.start().await?;