Skip to content

Commit 490778c

Browse files
committed
Fix lints
Signed-off-by: Jonathan Shi <[email protected]>
1 parent b10f6f5 commit 490778c

File tree

4 files changed

+7
-12
lines changed

4 files changed

+7
-12
lines changed

modin/core/dataframe/pandas/partitioning/partition_manager.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1234,13 +1234,13 @@ def apply_func_to_indices_both_axis(
12341234
all_parts = np.array(
12351235
[
12361236
[
1237-
partitions_copy[row_blk_idx, col_blk_idx]
1238-
for row_blk_idx, _ in row_partitions
1237+
partition_copy[row_blk_idx, col_blk_idx]
1238+
for row_blk_idx, _ in row_partitions_list
12391239
]
12401240
for col_blk_idx, _ in col_partitions_list
12411241
]
12421242
).flatten()
1243-
self._update_partition_dimension_caches(all_parts)
1243+
cls._update_partition_dimension_caches(all_parts)
12441244

12451245
def compute_part_size(indexer, remote_part, part_idx, axis):
12461246
"""Compute indexer length along the specified axis for the passed partition."""

modin/core/execution/dask/implementations/pandas_on_dask/dataframe/dataframe.py

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -72,14 +72,9 @@ def len_fn(df):
7272
return [partition.apply(len_fn)._data]
7373
elif partition.axis == axis:
7474
return [
75-
ptn.apply(len_fn)._data
76-
for ptn in partition.list_of_block_partitions
75+
ptn.apply(len_fn)._data for ptn in partition.list_of_block_partitions
7776
]
78-
return [
79-
partition.list_of_block_partitions[0]
80-
.apply(len_fn)
81-
._data
82-
]
77+
return [partition.list_of_block_partitions[0].apply(len_fn)._data]
8378

8479
@property
8580
def _row_lengths(self):

modin/core/execution/dask/implementations/pandas_on_dask/partitioning/virtual_partition.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -421,7 +421,7 @@ def width(self):
421421
for obj in self.list_of_partitions_to_combine
422422
]
423423
new_widths = DaskWrapper.materialize(
424-
[cache for cache in caches if isinstance(promise, Future)]
424+
[cache for cache in caches if isinstance(cache, Future)]
425425
)
426426
dask_idx = 0
427427
for i, cache in enumerate(caches):

modin/core/execution/ray/implementations/pandas_on_ray/partitioning/virtual_partition.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -427,7 +427,7 @@ def width(self):
427427
for obj in self.list_of_partitions_to_combine
428428
]
429429
new_widths = ray.get(
430-
[cache for cache in caches if isinstance(promise, ObjectIDType)]
430+
[cache for cache in caches if isinstance(cache, ObjectIDType)]
431431
)
432432
ray_idx = 0
433433
for i, cache in enumerate(caches):

0 commit comments

Comments
 (0)