Skip to content

Commit 456cd74

Browse files
authored
Merge pull request #686 from ydb-platform/Fix-typo-in-topic-writer
Fix typo in topic writer
2 parents cdb65a6 + 52cbefb commit 456cd74

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/_topic_writer/topic_writer.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -213,10 +213,10 @@ def messages_to_proto_requests(
213213
tx_identity: Optional[TransactionIdentity],
214214
) -> List[StreamWriteMessage.FromClient]:
215215

216-
gropus = _slit_messages_for_send(messages)
216+
groups = _split_messages_for_send(messages)
217217

218218
res = [] # type: List[StreamWriteMessage.FromClient]
219-
for group in gropus:
219+
for group in groups:
220220
req = StreamWriteMessage.FromClient(
221221
StreamWriteMessage.WriteRequest(
222222
messages=list(map(InternalMessage.to_message_data, group)),
@@ -254,7 +254,7 @@ def messages_to_proto_requests(
254254
)
255255

256256

257-
def _slit_messages_for_send(
257+
def _split_messages_for_send(
258258
messages: List[InternalMessage],
259259
) -> List[List[InternalMessage]]:
260260
codec_groups = [] # type: List[List[InternalMessage]]

0 commit comments

Comments
 (0)