We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent da71a82 commit 15b8afbCopy full SHA for 15b8afb
dask/dataframe/utils.py
@@ -631,12 +631,12 @@ def index(x):
631
results = get(ddf.dask, ddf.__dask_keys__())
632
for i, df in enumerate(results[:-1]):
633
if len(df):
634
- assert index(df).min() >= ddf.divisions[i]
635
- assert index(df).max() < ddf.divisions[i + 1]
+ assert min(index(df)) >= ddf.divisions[i]
+ assert max(index(df)) < ddf.divisions[i + 1]
636
637
if len(results[-1]):
638
- assert index(results[-1]).min() >= ddf.divisions[-2]
639
- assert index(results[-1]).max() <= ddf.divisions[-1]
+ assert min(index(results[-1])) >= ddf.divisions[-2]
+ assert max(index(results[-1])) <= ddf.divisions[-1]
640
641
642
def assert_sane_keynames(ddf):
0 commit comments