Defer import

dask · Feb 1, 2023 · 0041e58 · 0041e58
1 parent be5c5ad
commit 0041e58
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/distributed/shuffle/_merge.py b/distributed/shuffle/_merge.py
@@ -8,7 +8,6 @@
 
 from dask.base import tokenize
 from dask.core import keys_in_tasks
-from dask.dataframe.core import Index, new_dd_object
 from dask.dataframe.shuffle import partitioning_index
 from dask.highlevelgraph import HighLevelGraph
 from dask.layers import Layer
@@ -37,6 +36,8 @@ def hash_join_p2p(
     suffixes=("_x", "_y"),
     indicator=False,
 ):
+    from dask.dataframe.core import Index, new_dd_object
+
     if npartitions is None:
         npartitions = max(lhs.npartitions, rhs.npartitions)