Skip to content

Commit b9919b5

Browse files
authored
Fix class name issue with modern versions of dask.distributed (#351)
1 parent cbf9a62 commit b9919b5

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

adaptive/runner.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -806,7 +806,9 @@ def _ensure_executor(executor):
806806
return executor
807807
elif with_ipyparallel and isinstance(executor, ipyparallel.Client):
808808
return executor.executor()
809-
elif with_distributed and isinstance(executor, distributed.Client):
809+
elif with_distributed and isinstance(
810+
executor, (distributed.Client, distributed.client.Client)
811+
):
810812
return executor.get_executor()
811813
else:
812814
raise TypeError(

0 commit comments

Comments
 (0)