Skip to content

Commit

Permalink
fix typos
Browse files Browse the repository at this point in the history
Signed-off-by: Rehan Durrani <rehan@ponder.io>
  • Loading branch information
RehanSD committed Jul 12, 2022
1 parent a761182 commit 6a9855c
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ def __init__(self, list_of_blocks, get_ip=False, full_axis=True, call_queue=None
# extend and combine the lists of physical partitions.
if (
next(
o
obj
for obj in list_of_blocks
if isinstance(obj, PandasOnDaskDataframeVirtualPartition)
).axis
Expand All @@ -90,7 +90,7 @@ def __init__(self, list_of_blocks, get_ip=False, full_axis=True, call_queue=None
) if isinstance(
obj, PandasOnDaskDataframeVirtualPartition
) else new_list_of_blocks.append(
o
obj
)
self.list_of_partitions_to_combine = new_list_of_blocks
# Materialize partitions if the axis of this virtual does not match the virtual partitions
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ def __init__(self, list_of_blocks, get_ip=False, full_axis=True, call_queue=None
# extend and combine the lists of physical partitions.
if (
next(
o
obj
for obj in list_of_blocks
if isinstance(obj, PandasOnRayDataframeVirtualPartition)
).axis
Expand All @@ -90,7 +90,7 @@ def __init__(self, list_of_blocks, get_ip=False, full_axis=True, call_queue=None
) if isinstance(
obj, PandasOnRayDataframeVirtualPartition
) else new_list_of_blocks.append(
o
obj
)
self.list_of_partitions_to_combine = new_list_of_blocks
# Materialize partitions if the axis of this virtual does not match the virtual partitions
Expand Down
4 changes: 2 additions & 2 deletions modin/test/storage_formats/pandas/test_internals.py
Original file line number Diff line number Diff line change
Expand Up @@ -121,10 +121,10 @@ def func_to_apply(partition, row_internal_indices, col_internal_indices, item):
[
"many_small_dfs",
"concatted_df_with_small_dfs",
"large_df_plust_small_dfs",
"large_df_plus_small_dfs",
],
)
def test_rebalance_partitions(test_type, large_df, col_length):
def test_rebalance_partitions(test_type):
if test_type == "many_small_dfs":
small_dfs = [
pd.DataFrame(
Expand Down

0 comments on commit 6a9855c

Please sign in to comment.