tokio-cron-scheduler
tokio-cron-scheduler copied to clipboard
mvniekerk
Schedule tasks on Tokio using cron-like annotation
Hi, thank's for the effort being done. Recently, I hit an issue that if `scheduler.spawn()` is called in the code, without actual tasks, my server blocks. I started reviewing code...
I have around 1000 jobs running simultaneously, the default broadcast channel size is 200, this causes the receiver side to receive a `RecvError::Lagged` error, and this causes the scheduler to...
It would be nice to add a feature for sharing app state across the jobs, something similar like https://docs.rs/actix-web/4.4.1/actix_web/web/struct.Data.html ```rust // This struct represents state struct SchedulerState { config: AppConfig,...
Is it possible to make sure a task doesn't run concurrent with itself? Say a task repeats every 10 seconds, and sometimes it takes 15 seconds to complete so the...
Is there any particular reason why channel capacity is limited to 200? I have a use case where I need to schedule huge amount of jobs, which should be executed...
I use this library to run a twitter bot, but I must have changed something, and lately every time the cron job actually starts, it stops immediately with a generic...
Hello, I am currently working with a repeated_async type job in my project, where the job runs at an interval of 2 seconds. In most cases, it functions as expected....
For now I see only one way to resume jobs execution after reloading service. I have added custom wrapper over metadata_storage to get all jobs ids then data and use...
On [tokio-cron-scheduler](https://crates.io/crates/tokio-cron-scheduler) there is example bellow ```rust use tokio_cron_scheduler::{JobScheduler, JobToRun, Job}; #[tokio::main] async fn main() { let mut sched = JobScheduler::new().await; sched.add(Job::new("1/10 * * * * *", |uuid, l| {...
We currently use MongoDB as a primary database for one of our services that aim to use this library. And we were hoping to be able to use MongoDB as...
