bug fixed
This commit is contained in:
parent
b2c439de7c
commit
72f3d63eb5
|
@ -91,25 +91,25 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||||
sched.clone(),
|
sched.clone(),
|
||||||
api_config.clone(),
|
api_config.clone(),
|
||||||
)?;
|
)?;
|
||||||
member_scheduler.queue().await;
|
member_scheduler.queue().await?;
|
||||||
let balance_scheduler = schedulers::balance::scheduler::Scheduler::get_instance(
|
let balance_scheduler = schedulers::balance::scheduler::Scheduler::get_instance(
|
||||||
pool.clone(),
|
pool.clone(),
|
||||||
sched.clone(),
|
sched.clone(),
|
||||||
api_config.clone(),
|
api_config.clone(),
|
||||||
)?;
|
)?;
|
||||||
balance_scheduler.queue().await;
|
balance_scheduler.queue().await?;
|
||||||
let vendor_scheduler = schedulers::vendor::scheduler::Scheduler::get_instance(
|
let vendor_scheduler = schedulers::vendor::scheduler::Scheduler::get_instance(
|
||||||
pool.clone(),
|
pool.clone(),
|
||||||
sched.clone(),
|
sched.clone(),
|
||||||
api_config.clone(),
|
api_config.clone(),
|
||||||
)?;
|
)?;
|
||||||
vendor_scheduler.queue().await;
|
vendor_scheduler.queue().await?;
|
||||||
let game_scheduler = schedulers::game::scheduler::Scheduler::get_instance(
|
let game_scheduler = schedulers::game::scheduler::Scheduler::get_instance(
|
||||||
pool.clone(),
|
pool.clone(),
|
||||||
sched.clone(),
|
sched.clone(),
|
||||||
api_config.clone(),
|
api_config.clone(),
|
||||||
)?;
|
)?;
|
||||||
game_scheduler.queue().await;
|
game_scheduler.queue().await?;
|
||||||
|
|
||||||
let _h_scheduler = sched.start().await?;
|
let _h_scheduler = sched.start().await?;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user