Skip to content

Commit 1e863e7

Browse files
committed
fix other bad maps
Signed-off-by: Jonathan Shi <[email protected]>
1 parent 2ffefdb commit 1e863e7

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

modin/core/dataframe/pandas/interchange/dataframe_protocol/column.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ def get_chunks(
292292
new_lengths = [chunksize] * n_chunks
293293
new_lengths[-1] = n_rows % n_chunks + new_lengths[-1]
294294

295-
new_partitions = self._col._partition_mgr_cls.map_partitions(
295+
new_partitions = self._col._partition_mgr_cls.map_partitions_full_axis(
296296
self._col._partitions,
297297
lambda df: df,
298298
axis=0,

modin/core/dataframe/pandas/interchange/dataframe_protocol/dataframe.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ def get_chunks(
176176
new_lengths = [chunksize] * n_chunks
177177
new_lengths[-1] = n_rows % n_chunks + new_lengths[-1]
178178

179-
new_partitions = self._df._partition_mgr_cls.map_partitions(
179+
new_partitions = self._df._partition_mgr_cls.map_partitions_full_axis(
180180
self._df._partitions,
181181
lambda df: df,
182182
axis=0,

modin/core/execution/ray/implementations/pandas_on_ray/io/io.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -112,8 +112,8 @@ def func(df):
112112

113113
# Ensure that the metadata is syncrhonized
114114
qc._modin_frame._propagate_index_objs(axis=None)
115-
result = qc._modin_frame.map(
116-
func, axis=1, full_axis=True, new_index=[], new_columns=[]
115+
result = qc._modin_frame.map_full_axis(
116+
func, axis=1, new_index=[], new_columns=[]
117117
)
118118
# FIXME: we should be waiting for completion less expensively, maybe use _modin_frame.materialize()?
119119
result.to_pandas() # blocking operation
@@ -230,7 +230,7 @@ def func(df, **kw):
230230
RayWrapper.materialize(signals.send.remote(0))
231231
# Ensure that the metadata is syncrhonized
232232
qc._modin_frame._propagate_index_objs(axis=None)
233-
result = qc._modin_frame._partition_mgr_cls.map_partitions(
233+
result = qc._modin_frame._partition_mgr_cls.map_partitions_full_axis(
234234
qc._modin_frame._partitions,
235235
func,
236236
axis=1,
@@ -309,7 +309,7 @@ def func(df, **kw):
309309

310310
# Ensure that the metadata is synchronized
311311
qc._modin_frame._propagate_index_objs(axis=None)
312-
result = qc._modin_frame._partition_mgr_cls.map_partitions(
312+
result = qc._modin_frame._partition_mgr_cls.map_partitions_full_axis(
313313
qc._modin_frame._partitions,
314314
func,
315315
axis=1,

0 commit comments

Comments
 (0)