Fix a problem when number of input tasks is lower than number of workers

ITISFoundation · Nov 28, 2024 · bd5adb1 · bd5adb1
1 parent 0594c67
commit bd5adb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/docker_scripts/parallelrunner.py b/docker_scripts/parallelrunner.py
@@ -155,7 +155,7 @@ def run_input_tasks(self, input_tasks, tasks_uuid):
         batch_mode = self.settings.batch_mode
 
         if batch_mode:
-            n_of_batches = number_of_workers
+            n_of_batches = min(number_of_workers, len(input_tasks))
         else:
             n_of_batches = len(input_tasks)