diff --git a/src/depiction_targeted_preprocbatch/executor.py b/src/depiction_targeted_preprocbatch/executor.py index 2fdced0..726bfd1 100644 --- a/src/depiction_targeted_preprocbatch/executor.py +++ b/src/depiction_targeted_preprocbatch/executor.py @@ -70,7 +70,7 @@ def run(self, n_jobs: int) -> None: ) for job in batch_dataset.jobs ] - parallel = joblib.Parallel(n_jobs=n_jobs, verbose=10) + parallel = joblib.Parallel(n_jobs=n_jobs, verbose=10, backend="multiprocessing") parallel(joblib.delayed(self.run_job)(job) for job in jobs) def run_job(self, job: BatchJob) -> None: