调试

job_video_processing.py

@@ -10,7 +10,7 @@ def video_ai_task_start():
     with ThreadPoolExecutor( max_workers=max_workers) as executor:
         while True:
             try:
-                redis_task_list = ['task:video_ai_top']
+                redis_task_list = ['task:video_ai_top', 'task:video_ai_recommend'] * 3
                 futures = []
                 start_time = time.time()  # 记录开始时间