too parallel jobs

Author: studyfranco

src/gestionar_show.py

@@ -70,7 +70,7 @@ def process_episode(files, folder_id, episode_number, database_url):
                     mergeVideo.default_audio = True
                     mergeVideo.errors_merge = []
 
-                    video.ffmpeg_pool_audio_convert = Pool(processes=int(tools.core_to_use/1.5))
+                    video.ffmpeg_pool_audio_convert = Pool(processes=int(tools.core_to_use/1.7))
                     video.ffmpeg_pool_big_job = Pool(processes=1)
                     try:
                         if tools.dev:
@@ -221,7 +221,7 @@ def process_files_in_folder(folder_files,database_url):
 
     list_jobs = []
     global parrallel_jobs
-    parrallel_jobs = ProcessPoolExecutor(max_workers=3)
+    parrallel_jobs = ProcessPoolExecutor(max_workers=2)
 
     for folder_id, files in resultats_finaux.items():
         # Lancer le traitement des fichiers en parallèle

src/video.py

@@ -196,7 +196,7 @@ def extract_audio_in_part(self,language,exportParam,cutTime=None,asDefault=False
                         nameFilesExtractCut.append(nameOutFile)
                         cmd = baseCommand.copy()
                         cmd.extend(["-map", "0:"+str(audio['StreamOrder']), nameOutFile])
-                        self.ffmpeg_progress_audio.append(ffmpeg_pool_audio_convert.apply_async(tools.launch_cmdExt_with_timeout_reload, (cmd,3,500)))
+                        self.ffmpeg_progress_audio.append(ffmpeg_pool_audio_convert.apply_async(tools.launch_cmdExt_with_timeout_reload, (cmd,3,560)))
             else:
                 for audio in self.audios[language]:
                     if audio["compatible"]:
@@ -210,7 +210,7 @@ def extract_audio_in_part(self,language,exportParam,cutTime=None,asDefault=False
                             nameFilesExtractCut.append(nameOutFile)
                             cmd = baseCommand.copy()
                             cmd.extend(["-map", "0:"+str(audio['StreamOrder']), "-ss", cut[0], "-t", cut[1] , nameOutFile])
-                            self.ffmpeg_progress_audio.append(ffmpeg_pool_audio_convert.apply_async(tools.launch_cmdExt_with_timeout_reload, (cmd,3,500)))
+                            self.ffmpeg_progress_audio.append(ffmpeg_pool_audio_convert.apply_async(tools.launch_cmdExt_with_timeout_reload, (cmd,3,560)))
                             cutNumber += 1
 
     def remove_tmp_files(self,type_file=None):