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