Set to unbounded impl; tests pass.

alxmrs · Feb 15, 2024 · a6c0d77 · a6c0d77
1 parent 8d543de
commit a6c0d77
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/qarray/df.py b/qarray/df.py
@@ -74,7 +74,7 @@ def to_dd(ds: xr.Dataset) -> dd.DataFrame:
   divisions = tuple(np.cumsum([0] + block_lengths))  # 0 ==> start partition.
 
   def f(b: t.Dict[str, slice]) -> pd.DataFrame:
-    return to_pd(ds.isel(b))
+    return to_pd(ds.isel(b), bounded=False)
 
   return from_map(
     f,

diff --git a/qarray/df_test.py b/qarray/df_test.py
@@ -1,9 +1,8 @@
 import itertools
 import unittest
 
-import numpy as np
-import pandas as pd
 import dask.dataframe as dd
+import numpy as np
 import xarray as xr
 
 from .df import explode, to_dd

diff --git a/qarray/sql_test.py b/qarray/sql_test.py
@@ -1,4 +1,5 @@
 import unittest
+
 from dask_sql import Context
 
 from .df import to_dd