Do not call shutdown() in run_parallel() when jobs=1 (#13)

GianlucaFicarelli · web-flow · commit 7e67afa6be6b · 2024-05-03T13:00:13.000+02:00
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -1,6 +1,14 @@
 Changelog
 =========
 
+Version 0.2.4
+-------------
+
+Bug fixes
+~~~~~~~~~
+
+- Do not call ``get_reusable_executor().shutdown()`` when tasks are run serially in ``run_parallel()``.
+
 Version 0.2.3
 -------------
 
diff --git a/src/blueetl_core/parallel.py b/src/blueetl_core/parallel.py
@@ -117,7 +117,7 @@ def run_parallel(
             for i, task in enumerate(tasks)
         )
     finally:
-        if shutdown_executor and (not backend or backend == "loky"):
+        if shutdown_executor and (not backend or backend == "loky") and jobs != 1:
             # shutdown the pool of processes used by loky
             get_reusable_executor().shutdown(wait=True)
 

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@ def run_parallel(`
`117`	`117`	`for i, task in enumerate(tasks)`
`118`	`118`	`)`
`119`	`119`	`finally:`
`120`		`- if shutdown_executor and (not backend or backend == "loky"):`
	`120`	`+ if shutdown_executor and (not backend or backend == "loky") and jobs != 1:`
`121`	`121`	`# shutdown the pool of processes used by loky`
`122`	`122`	`get_reusable_executor().shutdown(wait=True)`
`123`	`123`