From 52cbefbf6a0607ae724b15df21d172d640749e2f Mon Sep 17 00:00:00 2001 From: Oleg Ovcharuk Date: Mon, 30 Jun 2025 09:30:18 +0300 Subject: [PATCH] Fix typo in topic writer --- ydb/_topic_writer/topic_writer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ydb/_topic_writer/topic_writer.py b/ydb/_topic_writer/topic_writer.py index a3e407ed..16feded7 100644 --- a/ydb/_topic_writer/topic_writer.py +++ b/ydb/_topic_writer/topic_writer.py @@ -213,10 +213,10 @@ def messages_to_proto_requests( tx_identity: Optional[TransactionIdentity], ) -> List[StreamWriteMessage.FromClient]: - gropus = _slit_messages_for_send(messages) + groups = _split_messages_for_send(messages) res = [] # type: List[StreamWriteMessage.FromClient] - for group in gropus: + for group in groups: req = StreamWriteMessage.FromClient( StreamWriteMessage.WriteRequest( messages=list(map(InternalMessage.to_message_data, group)), @@ -254,7 +254,7 @@ def messages_to_proto_requests( ) -def _slit_messages_for_send( +def _split_messages_for_send( messages: List[InternalMessage], ) -> List[List[InternalMessage]]: codec_groups = [] # type: List[List[InternalMessage]]