Skip to content

Commit

Permalink
Added comment
Browse files Browse the repository at this point in the history
  • Loading branch information
AndreyPavlenko committed Sep 29, 2023
1 parent 87a81bf commit 8842a0c
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions modin/core/dataframe/pandas/partitioning/partition_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -257,6 +257,9 @@ def groupby_reduce(
)
else:
mapped_partitions = cls.map_partitions(partitions, map_func)

# Assuming, that the output will not be larger than the input,
# keep the current number of partitions.
num_splits = min(len(partitions), NPartitions.get())
return cls.map_axis_partitions(
axis,
Expand Down

0 comments on commit 8842a0c

Please sign in to comment.