Skip to content

Commit 10ec9b2

Browse files
Fixed typing
Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
1 parent bbac8ce commit 10ec9b2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/ray/data/_internal/output_buffer.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ def has_next(self) -> bool:
9090
self._exceeded_buffer_row_limit() or self._exceeded_buffer_size_limit()
9191
)
9292

93-
def _exceeded_block_size_slice_limit(self, block: Block) -> bool:
93+
def _exceeded_block_size_slice_limit(self, block: BlockAccessor) -> bool:
9494
# Slice a block to respect the target max block size. We only do this if we are
9595
# more than 50% above the target block size, because this ensures that the last
9696
# block produced will be at least half the target block size.
@@ -101,7 +101,7 @@ def _exceeded_block_size_slice_limit(self, block: Block) -> bool:
101101
* self._output_block_size_option.target_max_block_size
102102
)
103103

104-
def _exceeded_block_row_slice_limit(self, block: Block) -> bool:
104+
def _exceeded_block_row_slice_limit(self, block: BlockAccessor) -> bool:
105105
# Slice a block to respect the target max rows per block. We only do this if we
106106
# are more than 50% above the target rows per block, because this ensures that
107107
# the last block produced will be at least half the target row count.

0 commit comments

Comments
 (0)