From ac70a36bf3df5277d9b2c40a7e9b0a6b4d98d0ae Mon Sep 17 00:00:00 2001 From: King Chung Huang Date: Mon, 7 Sep 2020 14:49:42 -0600 Subject: [PATCH] Refine import of Dask Client While the distributed module is technically the same as dask.distributed, the latter is the canonical way of accessing it. --- python_modules/libraries/dagster-dask/dagster_dask/resources.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python_modules/libraries/dagster-dask/dagster_dask/resources.py b/python_modules/libraries/dagster-dask/dagster_dask/resources.py index 82508aea21b5c..c069eac4f6319 100644 --- a/python_modules/libraries/dagster-dask/dagster_dask/resources.py +++ b/python_modules/libraries/dagster-dask/dagster_dask/resources.py @@ -8,7 +8,7 @@ String, resource, ) -from distributed import Client +from dask.distributed import Client DaskClusterTypes = {