Skip to content

Commit c40f579

Browse files
committed
fix call commit from sync reader
1 parent a8c48ab commit c40f579

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ydb/_topic_reader/topic_reader_sync.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ def commit(
126126
"""
127127
self._check_closed()
128128

129-
self._caller.call_sync(self._async_reader.commit(mess))
129+
self._caller.call_sync(lambda: self._async_reader.commit(mess))
130130

131131
def commit_with_ack(
132132
self,

0 commit comments

Comments
 (0)