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