|
|
@@ -22,13 +22,13 @@ def start_scheduler() -> None:
|
|
|
_scheduler = BackgroundScheduler(timezone=ZoneInfo("Asia/Shanghai"))
|
|
|
_scheduler.add_job(
|
|
|
run_decode_dispatch_job,
|
|
|
- trigger=CronTrigger(minute="*/5"),
|
|
|
- id="decode_dispatch_every_5min",
|
|
|
+ trigger=CronTrigger(minute="*/4"),
|
|
|
+ id="decode_dispatch_every_4min",
|
|
|
replace_existing=True,
|
|
|
next_run_time=datetime.now(ZoneInfo("Asia/Shanghai")),
|
|
|
)
|
|
|
_scheduler.start()
|
|
|
- logger.info("调度器已启动:立即触发一次,之后每5分钟执行一次")
|
|
|
+ logger.info("调度器已启动:立即触发一次,之后每4分钟执行一次")
|
|
|
|
|
|
|
|
|
def stop_scheduler() -> None:
|