调试

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']
+                redis_task_list = ['task:video_ai'] * 3
                 # 提交所有任务并等待完成
                 futures = [executor.submit( process_video_ai, redis_task ) for redis_task in redis_task_list]
                 wait( futures )  # 等待所有任务完成