@@ -8,7 +8,7 @@ max_workers = 10
def video_ai_task_start():
with ThreadPoolExecutor( max_workers=max_workers) as executor:
- redis_task_list = ['task:video_ai_top', 'task:video_ai_recommend']
+ redis_task_list = ['task:video_ai_top', 'task:video_ai_recommend'] * 3
# 任务索引
task_index = 0
while True:
