Skip to content

Commit 9c50985

Browse files
committed
pr comments
1 parent 7d4e663 commit 9c50985

3 files changed

Lines changed: 3 additions & 7 deletions

File tree

modin/core/execution/ray/implementations/cudf_on_ray/partitioning/partition_manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ def from_pandas(cls, df, return_dims=False):
125125
num_splits = GpuCount.get()
126126
put_func = cls._partition_class.put
127127
# For now, we default to row partitioning
128-
pandas_dfs = split_result_of_axis_func_pandas(0, num_splits, df)
128+
pandas_dfs = list(split_result_of_axis_func_pandas(0, num_splits, df))
129129
keys = [
130130
put_func(cls._get_gpu_managers()[i], pandas_dfs[i])
131131
for i in range(num_splits)

modin/core/storage_formats/cudf/parser.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,7 @@ def _split_result_for_readers(axis, num_splits, df): # pragma: no cover
3939
Returns:
4040
A list of pandas DataFrames.
4141
"""
42-
splits = split_result_of_axis_func_pandas(axis, num_splits, df)
43-
if not isinstance(splits, list):
44-
splits = [splits]
42+
splits = list(split_result_of_axis_func_pandas(axis, num_splits, df))
4543
return splits
4644

4745

modin/core/storage_formats/pandas/parsers.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -113,9 +113,7 @@ def _split_result_for_readers(axis, num_splits, df): # pragma: no cover
113113
list
114114
A list of pandas DataFrames.
115115
"""
116-
splits = split_result_of_axis_func_pandas(axis, num_splits, df)
117-
if not isinstance(splits, list):
118-
splits = [splits]
116+
splits = list(split_result_of_axis_func_pandas(axis, num_splits, df))
119117
return splits
120118

121119

0 commit comments

Comments
 (0)