We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b860281 commit 4b76603Copy full SHA for 4b76603
modin/core/dataframe/pandas/partitioning/partition_manager.py
@@ -576,7 +576,6 @@ def broadcast_axis_partitions(
576
# load-balance the data as well.
577
kw = {
578
"num_splits": num_splits,
579
- "other_axis_partition": right_partitions,
580
"maintain_partitioning": keep_partitioning,
581
}
582
if lengths:
@@ -591,6 +590,7 @@ def broadcast_axis_partitions(
591
590
left_partitions[i].apply(
592
preprocessed_map_func,
593
*(apply_func_args if apply_func_args else []),
+ other_axis_partition=right_partitions[i] if right_partitions is not None else None,
594
**kw,
595
**({"partition_idx": idx} if enumerate_partitions else {}),
596
**kwargs,
0 commit comments