Use dask.dataframe.core, not new dask-expr.

bluesky · Mar 12, 2024 · 2f1631c · 2f1631c
1 parent 52ec6b8
commit 2f1631c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tiled/client/dataframe.py b/tiled/client/dataframe.py
@@ -1,5 +1,5 @@
 import dask
-import dask.dataframe
+import dask.dataframe.core
 
 from ..serialization.table import deserialize_arrow, serialize_arrow
 from ..utils import APACHE_ARROW_FILE_MIME_TYPE, UNCHANGED
@@ -162,7 +162,7 @@ def read(self, columns=None):
 
         if columns is not None:
             meta = meta[columns]
-        ddf = dask.dataframe.DataFrame(
+        ddf = dask.dataframe.core.DataFrame(
             dask_tasks,
             name=name,
             meta=meta,