|
@@ -75,7 +75,7 @@ async def run():
|
|
|
logger.info(f"[处理] 开始启动")
|
|
|
scheduler.add_job(
|
|
|
ConsumptionSpiderRecommend.run,
|
|
|
- trigger=CronTrigger(hour='2-6', minute='*') # 2:00-6:59 每分钟执行一次
|
|
|
+ trigger=CronTrigger(hour='2-6', minute='*', second='*/30') # 2:00-6:59 每30s执行一次
|
|
|
)
|
|
|
scheduler.start()
|
|
|
await asyncio.Event().wait()
|