We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb98ede commit 3f425bfCopy full SHA for 3f425bf
ydb/aio/query/pool.py
@@ -61,7 +61,8 @@ async def acquire(self) -> QuerySession:
61
done, _ = await asyncio.wait((queue_get, task_stop), return_when=asyncio.FIRST_COMPLETED)
62
if task_stop in done:
63
queue_get.cancel()
64
- return await self._create_new_session()
+ raise RuntimeError("An attempt to take session from closed session pool.")
65
+
66
task_stop.cancel()
67
session = queue_get.result()
68
@@ -163,7 +164,7 @@ def __del__(self):
163
164
if self._should_stop.is_set() or self._loop.is_closed():
165
return
166
- self._loop.call_soon(functools.partial(self.stop))
167
+ self._loop.call_soon(self.stop)
168
169
170
class SimpleQuerySessionCheckoutAsync:
0 commit comments