|
|
@@ -65,7 +65,7 @@ SCHEDULER_TZ = ZoneInfo(SCHEDULER_TIMEZONE)
|
|
|
scheduler = AsyncIOScheduler(timezone=SCHEDULER_TZ)
|
|
|
|
|
|
# 并发控制
|
|
|
-MAX_CONCURRENT_TASKS = int(os.getenv("MAX_CONCURRENT_TASKS", "2"))
|
|
|
+MAX_CONCURRENT_TASKS = int(os.getenv("MAX_CONCURRENT_TASKS", "1"))
|
|
|
task_semaphore = asyncio.Semaphore(MAX_CONCURRENT_TASKS)
|
|
|
|
|
|
# 定时:派发间隔(秒)、单次任务超时(秒,默认 15 分钟)
|