|
@@ -222,7 +222,7 @@ class getVideo:
|
|
|
cls.remove_files(video_path_url)
|
|
cls.remove_files(video_path_url)
|
|
|
Common.logger("warning").warning(f"{name}的{task_mark}任务处理失败:{e}\n")
|
|
Common.logger("warning").warning(f"{name}的{task_mark}任务处理失败:{e}\n")
|
|
|
|
|
|
|
|
- batch_size = 1
|
|
+ batch_size = 2
|
|
|
with concurrent.futures.ThreadPoolExecutor(max_workers=batch_size) as executor:
|
|
with concurrent.futures.ThreadPoolExecutor(max_workers=batch_size) as executor:
|
|
|
index = 0
|
|
index = 0
|
|
|
while index < len(task_data):
|
|
while index < len(task_data):
|
