Use default executor when Runner(..., executor=None) (#389)

python-adaptive · Dec 2, 2022 · 6c69e88 · 6c69e88
1 parent 0a80755
commit 6c69e88
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/adaptive/runner.py b/adaptive/runner.py
@@ -182,7 +182,7 @@ def __init__(
         npoints_goal: int | None = None,
         end_time_goal: datetime | None = None,
         duration_goal: timedelta | int | float | None = None,
-        executor: (ExecutorTypes | None) = None,
+        executor: ExecutorTypes | None = None,
         ntasks: int = None,
         log: bool = False,
         shutdown_executor: bool = False,
@@ -934,11 +934,9 @@ def replay_log(
 # -- Internal executor-related, things
 
 
-def _ensure_executor(
-    executor: ExecutorTypes | None,
-) -> concurrent.Executor:
+def _ensure_executor(executor: ExecutorTypes | None) -> concurrent.Executor:
     if executor is None:
-        executor = concurrent.ProcessPoolExecutor()
+        executor = _default_executor()
 
     if isinstance(executor, concurrent.Executor):
         return executor