|
|
@@ -175,7 +175,7 @@ async def run():
|
|
|
scheduler = AsyncIOScheduler()
|
|
|
try:
|
|
|
logger.info(f"[处理 - trigger] 开始启动")
|
|
|
- scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=6)) # 每5分钟启动一次
|
|
|
+ scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=5)) # 每5分钟启动一次
|
|
|
scheduler.start()
|
|
|
await asyncio.Event().wait()
|
|
|
except KeyboardInterrupt:
|
