Skip to content

Commit 209a37d

Browse files
committed
Intermediate changes
commit_hash:24aa47673f664dfffb1ecde56dcf0bd5d1e5b8f7
1 parent 25b4109 commit 209a37d

File tree

6 files changed

+15
-6
lines changed

6 files changed

+15
-6
lines changed

contrib/python/ydb/py3/.dist-info/METADATA

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
Metadata-Version: 2.1
22
Name: ydb
3-
Version: 3.18.16
3+
Version: 3.18.17
44
Summary: YDB Python SDK
55
Home-page: http://github.com/ydb-platform/ydb-python-sdk
66
Author: Yandex LLC

contrib/python/ydb/py3/ya.make

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
PY3_LIBRARY()
44

5-
VERSION(3.18.16)
5+
VERSION(3.18.17)
66

77
LICENSE(Apache-2.0)
88

contrib/python/ydb/py3/ydb/_utilities.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,10 @@ def __iter__(self):
161161
return self
162162

163163
def _next(self):
164-
return self.wrapper(next(self.it))
164+
res = self.wrapper(next(self.it))
165+
if res is not None:
166+
return res
167+
return self._next()
165168

166169
def next(self):
167170
return self._next()

contrib/python/ydb/py3/ydb/aio/_utilities.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,10 @@ def __aiter__(self):
1717
return self
1818

1919
async def _next(self):
20-
return self.wrapper(await self.it.__anext__())
20+
res = self.wrapper(await self.it.__anext__())
21+
if res is not None:
22+
return res
23+
return await self._next()
2124

2225
async def next(self):
2326
return await self._next()

contrib/python/ydb/py3/ydb/query/base.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -192,4 +192,7 @@ def wrap_execute_query_response(
192192
elif tx and response_pb.tx_meta and not tx.tx_id:
193193
tx._move_to_beginned(response_pb.tx_meta.id)
194194

195-
return convert.ResultSet.from_message(response_pb.result_set, settings)
195+
if response_pb.HasField("result_set"):
196+
return convert.ResultSet.from_message(response_pb.result_set, settings)
197+
198+
return None
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
VERSION = "3.18.16"
1+
VERSION = "3.18.17"

0 commit comments

Comments
 (0)