diff --git a/platform/backend/app/core/scheduler.py b/platform/backend/app/core/scheduler.py index 65d5a7a..1f03c61 100644 --- a/platform/backend/app/core/scheduler.py +++ b/platform/backend/app/core/scheduler.py @@ -25,7 +25,7 @@ class TaskScheduler: logger.warning("Scheduler already started") return # 使用 CronTrigger 设置每日固定时间点 - # 顺序: 搜索缓存(01:00)→采集(01:30)→趋势(03:00)→生成(03:30)→审查(04:30)→源优化(05:00)→指标(06:00) + # 顺序: 搜索缓存(01:00)→趋势(01:10)→采集(01:30)→创作(02:00)→审查(03:00)→源优化(05:00)→指标(06:00) self.scheduler.add_job( self._run_refresh_search_cache, CronTrigger(hour=1, minute=0), @@ -34,22 +34,22 @@ class TaskScheduler: max_instances=1, coalesce=True ) + self.scheduler.add_job( + self._run_fetch_trends, + CronTrigger(hour=1, minute=10), + id='scheduled_fetch_trends', + replace_existing=True, + max_instances=1, + coalesce=True + ) self.scheduler.add_job( self._run_collect, CronTrigger(hour=1, minute=30), id='scheduled_collect', ) - self.scheduler.add_job( - self._run_fetch_trends, - CronTrigger(hour=3, minute=0), - id='scheduled_fetch_trends', - replace_existing=True, - max_instances=1, - coalesce=True - ) self.scheduler.add_job( self._run_generate, - CronTrigger(hour=3, minute=30), + CronTrigger(hour=2, minute=0), id='scheduled_generate', replace_existing=True, max_instances=1, @@ -57,7 +57,7 @@ class TaskScheduler: ) self.scheduler.add_job( self._run_optimize, - CronTrigger(hour=4, minute=30), + CronTrigger(hour=3, minute=0), id='scheduled_optimize', replace_existing=True, max_instances=1, @@ -81,7 +81,7 @@ class TaskScheduler: ) self.scheduler.start() self._started = True - logger.info("Scheduler started: 01:00 search_cache → 01:30 collect → 03:00 trends → 03:30 generate → 04:30 review → 05:00 optimize_sources → 06:00 metrics_sync") + logger.info("Scheduler started: 01:00 search 01:10 trends 01:30 collect 02:00 create 03:00 review 05:00 sources 06:00 metrics") def shutdown(self): if self.scheduler.running: self.scheduler.shutdown()