File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -182,7 +182,7 @@ def __init__(
182182 npoints_goal : int | None = None ,
183183 end_time_goal : datetime | None = None ,
184184 duration_goal : timedelta | int | float | None = None ,
185- executor : ( ExecutorTypes | None ) = None ,
185+ executor : ExecutorTypes | None = None ,
186186 ntasks : int = None ,
187187 log : bool = False ,
188188 shutdown_executor : bool = False ,
@@ -934,11 +934,9 @@ def replay_log(
934934# -- Internal executor-related, things
935935
936936
937- def _ensure_executor (
938- executor : ExecutorTypes | None ,
939- ) -> concurrent .Executor :
937+ def _ensure_executor (executor : ExecutorTypes | None ) -> concurrent .Executor :
940938 if executor is None :
941- executor = concurrent . ProcessPoolExecutor ()
939+ executor = _default_executor ()
942940
943941 if isinstance (executor , concurrent .Executor ):
944942 return executor
You can’t perform that action at this time.
0 commit comments