joblib parallel

Former-commit-id: 7a47740
bhklab · Jun 21, 2022 · cbfe87a · cbfe87a
1 parent 4f24fd6
commit cbfe87a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/imgtools/autopipeline.py b/imgtools/autopipeline.py
@@ -404,10 +404,10 @@ def run(self):
             print("Dataset already processed...")
             shutil.rmtree(pathlib.Path(self.output_directory, ".temp").as_posix())
         else:
-            # Parallel(n_jobs=self.n_jobs, verbose=verbose)(
-            #         delayed(self._process_wrapper)(subject_id) for subject_id in subject_ids)
-            for subject_id in subject_ids:
-                self._process_wrapper(subject_id)
+            Parallel(n_jobs=self.n_jobs, verbose=verbose)(
+                    delayed(self._process_wrapper)(subject_id) for subject_id in subject_ids)
+            # for subject_id in subject_ids:
+            #     self._process_wrapper(subject_id)
             self.save_data()
 
 def main():