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