From 6fbdf097b3de8584812cf77919b9a1916e29bc19 Mon Sep 17 00:00:00 2001 From: v6ole Date: Sat, 9 May 2026 15:55:56 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=20c?= =?UTF-8?q?ron=20=E8=A1=A8=E8=BE=BE=E5=BC=8F=E6=94=B9=E4=B8=BA=E4=BB=8E?= =?UTF-8?q?=E9=85=8D=E7=BD=AE=E8=AF=BB=E5=8F=96=EF=BC=8C=E6=B6=88=E9=99=A4?= =?UTF-8?q?=E7=A1=AC=E7=BC=96=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/scheduler/jobs.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/app/scheduler/jobs.py b/app/scheduler/jobs.py index 9dfc41f..86c711b 100644 --- a/app/scheduler/jobs.py +++ b/app/scheduler/jobs.py @@ -1,6 +1,7 @@ import logging from apscheduler.schedulers.asyncio import AsyncIOScheduler +from apscheduler.triggers.cron import CronTrigger from app.api.deps import get_crawl_service from app.config import settings @@ -29,17 +30,15 @@ async def scheduled_crawl(): def start_scheduler(): if not settings.scheduler_enabled: return + trigger = CronTrigger.from_crontab(settings.scheduler_cron, timezone="Asia/Shanghai") scheduler.add_job( scheduled_crawl, - "cron", - hour="8,14,18", - minute="0", + trigger=trigger, id="scheduled_crawl", name="定时爬取", - timezone="Asia/Shanghai", ) scheduler.start() - logger.info("APScheduler 已启动 (8:00, 14:00, 18:00)") + logger.info(f"APScheduler 已启动 (cron: {settings.scheduler_cron})") def shutdown_scheduler():