|
@@ -479,7 +479,7 @@ def run():
|
|
|
scheduler = BlockingScheduler()
|
|
scheduler = BlockingScheduler()
|
|
|
try:
|
|
try:
|
|
|
logger.info(f"[处理] 开始启动")
|
|
logger.info(f"[处理] 开始启动")
|
|
|
- scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=5)) # 每5分钟启动一次
|
|
|
|
|
|
|
+ scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=1)) # 每1分钟启动一次
|
|
|
scheduler.start()
|
|
scheduler.start()
|
|
|
except KeyboardInterrupt:
|
|
except KeyboardInterrupt:
|
|
|
pass
|
|
pass
|
