|
|
@@ -340,9 +340,9 @@ async def startup():
|
|
|
logger.info(f"最大并发任务数: {MAX_CONCURRENT_TASKS}")
|
|
|
|
|
|
# 配置定时任务（从 demand_content 联表查询未处理需求，无需外部 API）
|
|
|
- scheduler.add_job(scheduled_task, "cron", minute="*/10")
|
|
|
+ scheduler.add_job(scheduled_task, "cron", minute="*/5")
|
|
|
scheduler.start()
|
|
|
- logger.info("定时任务已启动：每 10 分钟执行一次（从数据库获取待处理需求）")
|
|
|
+ logger.info("定时任务已启动：每 5 分钟执行一次（从数据库获取待处理需求）")
|
|
|
|
|
|
logger.info("服务启动完成")
|
|
|
logger.info("=" * 60)
|
