Skip to content

Commit c86e798

Browse files
committed
style fixes
1 parent e0f4e4b commit c86e798

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/_topic_reader/topic_reader_asyncio.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -369,16 +369,16 @@ def _get_first_batch(self) -> typing.Tuple[int, datatypes.PublicBatch]:
369369
return first_id, batch
370370

371371
def _cut_batch_by_max_messages(
372-
batch: datatypes.PublicBatch,
373-
max_messages: int,
372+
batch: datatypes.PublicBatch,
373+
max_messages: int,
374374
) -> typing.Tuple[datatypes.PublicBatch, datatypes.PublicBatch]:
375375
initial_length = len(batch.messages)
376376
one_message_size = batch._bytes_size // initial_length
377377

378378
new_batch = datatypes.PublicBatch(
379379
messages=batch.messages[:max_messages],
380380
_partition_session=batch._partition_session,
381-
_bytes_size=one_message_size*max_messages,
381+
_bytes_size=one_message_size * max_messages,
382382
_codec=batch._codec,
383383
)
384384

0 commit comments

Comments
 (0)