Skip to content

Commit 2bee743

Browse files
committed
fix anext for python 3.8
1 parent 96a749b commit 2bee743

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ydb/_topic_wrapper/common.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ def __init__(self, iterator: typing.AsyncIterator[typing.Any]):
118118

119119
async def get(self) -> typing.Any:
120120
try:
121-
return anext(self._iterator)
121+
return self._iterator.__anext__()
122122
except StopAsyncIteration:
123123
raise asyncio.QueueEmpty()
124124

0 commit comments

Comments
 (0)