Skip to content

Commit c60269b

Browse files
committed
fix set_index
1 parent 51058a5 commit c60269b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dask/dataframe/shuffle.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,8 @@ def _calculate_divisions(
5454
"""
5555
sizes = df.map_partitions(sizeof) if repartition else []
5656
divisions = partition_col._repartition_quantiles(npartitions, upsample=upsample)
57-
mins = partition_col.map_partitions(M.min)
58-
maxes = partition_col.map_partitions(M.max)
57+
mins = partition_col.map_partitions(M.min, enforce_metadata=False)
58+
maxes = partition_col.map_partitions(M.max, enforce_metadata=False)
5959

6060
try:
6161
divisions, sizes, mins, maxes = compute(divisions, sizes, mins, maxes)

0 commit comments

Comments
 (0)