bet/beteran-api-kgon-server-service
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

scheduler is changed

Browse Source
This commit is contained in:
병준 박 2022-08-19 08:59:48 +00:00
parent a26d5bb6bc
commit e87060a940
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/schedulers/balance/scheduler.rs
View File

@ -65,7 +65,7 @@ impl Scheduler {
} }
async fn balance_for_user(&'static self) -> Result<(), Box<dyn std::error::Error>> { async fn balance_for_user(&'static self) -> Result<(), Box<dyn std::error::Error>> {
let j_synchronization = Job::new_async("0 0 0/1 * * *", move |_uuid, _l| { let j_synchronization = Job::new_async("0 0/3 * * * ?", move |_uuid, _l| {
Box::pin(async move { Box::pin(async move {
let start_at = (chrono::Utc::now()).timestamp(); let start_at = (chrono::Utc::now()).timestamp();
@ -137,7 +137,7 @@ impl Scheduler {
} }
async fn balance_for_partner(&'static self) -> Result<(), Box<dyn std::error::Error>> { async fn balance_for_partner(&'static self) -> Result<(), Box<dyn std::error::Error>> {
let j_synchronization = Job::new_async("0 0 0/1 * * *", move |_uuid, _l| { let j_synchronization = Job::new_async("0 0/3 * * * ?", move |_uuid, _l| {
Box::pin(async move { Box::pin(async move {
let start_at = (chrono::Utc::now()).timestamp(); let start_at = (chrono::Utc::now()).timestamp();

2
src/schedulers/game/scheduler.rs
View File

@ -64,7 +64,7 @@ impl Scheduler {
} }
async fn list_vendors(&'static self) -> Result<(), Box<dyn std::error::Error>> { async fn list_vendors(&'static self) -> Result<(), Box<dyn std::error::Error>> {
let j_synchronization = Job::new_async("0 0 0/1 * * *", move |_uuid, _l| { let j_synchronization = Job::new_async("0 0/3 * * * ?", move |_uuid, _l| {
Box::pin(async move { Box::pin(async move {
let start_at = (chrono::Utc::now()).timestamp(); let start_at = (chrono::Utc::now()).timestamp();

2
src/schedulers/member/scheduler.rs
View File

@ -60,7 +60,7 @@ impl Scheduler {
} }
async fn list_members(&'static self) -> Result<(), Box<dyn std::error::Error>> { async fn list_members(&'static self) -> Result<(), Box<dyn std::error::Error>> {
let j_synchronization = Job::new_async("0 0 0/1 * * *", move |_uuid, _l| { let j_synchronization = Job::new_async("0 0/3 * * * ?", move |_uuid, _l| {
Box::pin(async move { Box::pin(async move {
let start_at = (chrono::Utc::now()).timestamp(); let start_at = (chrono::Utc::now()).timestamp();