Skip to content

Commit b68cdd4

Browse files
committed
style fixes
1 parent b2e88b5 commit b68cdd4

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
@@ -389,16 +389,16 @@ def _get_first_batch(self) -> typing.Tuple[int, datatypes.PublicBatch]:
389389
return partition_session_id, batch
390390

391391
def _cut_batch_by_max_messages(
392-
batch: datatypes.PublicBatch,
393-
max_messages: int,
392+
batch: datatypes.PublicBatch,
393+
max_messages: int,
394394
) -> typing.Tuple[datatypes.PublicBatch, datatypes.PublicBatch]:
395395
initial_length = len(batch.messages)
396396
one_message_size = batch._bytes_size // initial_length
397397

398398
new_batch = datatypes.PublicBatch(
399399
messages=batch.messages[:max_messages],
400400
_partition_session=batch._partition_session,
401-
_bytes_size=one_message_size*max_messages,
401+
_bytes_size=one_message_size * max_messages,
402402
_codec=batch._codec,
403403
)
404404

0 commit comments

Comments
 (0)