Browse Source

增加线程数

zhangyong 9 months ago
parent
commit
e3077d4e79
2 changed files with 2 additions and 2 deletions
  1. 1 1
      data_channel/kuaishouchuangzuozhe.py
  2. 1 1
      video_rewriting/video_prep.py

+ 1 - 1
data_channel/kuaishouchuangzuozhe.py

@@ -125,7 +125,7 @@ class KsFeedVideo:
         age_range = user_range['ageRange']
         age_range = user_range['ageRange']
         value = age_range[5]['value']
         value = age_range[5]['value']
         value = int(value.strip('%'))
         value = int(value.strip('%'))
-        if value >= 50:
+        if value >= 45:
             return False, value
             return False, value
         else:
         else:
             return True, value
             return True, value

+ 1 - 1
video_rewriting/video_prep.py

@@ -315,7 +315,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):