change 间隔时间

workers/video_insight_select_work.py

@@ -20,7 +20,7 @@ def requirement_insight():
         logger.info(f"视频需求点洞察")
         # redis_task = "task:video_insight"
         redis_trigger_task = "task:video_trigger_insight"
-        sql =f'select clickobjectid as video_id from loghubods.user_share_log where dt = {dt} and topic = "click" group by clickobjectid order by count(distinct machinecode) desc limit 900'
+        sql =f'select clickobjectid as video_id from loghubods.user_share_log where dt = {dt} and topic = "click" group by clickobjectid order by count(distinct machinecode) desc limit 1200'
         data = OdpsDataCount.main(sql)
         if not data:
             return

workers/video_insight_trigger_work.py

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