|
@@ -6,7 +6,7 @@ max_workers = 5 # 最大线程数
|
|
|
|
|
|
|
|
|
|
|
|
|
def video_ai_task_start():
|
|
def video_ai_task_start():
|
|
|
- redis_task_list = ['task:video_ai_top', 'task:video_ai_top', 'task:video_ai_top', 'task:video_ai_recommend', 'task:video_ai_recommend']
|
|
|
|
|
|
|
+ redis_task_list = ['task:video_ai_top', 'task:video_ai_top', 'task:video_ai_recommend', 'task:video_ai_recommend', 'task:video_ai_recommend']
|
|
|
futures = [] # 用来存储任务的 Future 对象
|
|
futures = [] # 用来存储任务的 Future 对象
|
|
|
task_index = 0
|
|
task_index = 0
|
|
|
|
|
|
