feat: 改为10s执行一次
This commit is contained in:
parent
a750a630df
commit
60463c5ad0
|
|
@ -182,8 +182,8 @@ async fn main() {
|
|||
// 创建定时任务调度器
|
||||
let scheduler = JobScheduler::new().await.expect("Failed to create scheduler");
|
||||
|
||||
// 创建每10分钟执行一次的任务
|
||||
let analyze_job = Job::new_async("0 */10 * * * *", move |_uuid, _l| {
|
||||
// 创建每10s执行一次的任务
|
||||
let analyze_job = Job::new_async("*/10 * * * * *", move |_uuid, _l| {
|
||||
Box::pin(async move {
|
||||
analyze_chunks().await;
|
||||
})
|
||||
|
|
|
|||
Loading…
Reference in New Issue