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 1c0807f commit 40d0d08Copy full SHA for 40d0d08
ydb/aio/query/pool.py
@@ -85,7 +85,7 @@ async def acquire_wih_timeout(self, timeout: float):
85
session = task_wait.result()
86
return session
87
except asyncio.TimeoutError:
88
- raise issues.SessionPoolEmpty("Timeout on acquire session")
+ raise issues.SessionPoolEmpty("Timeout on acquire session")
89
90
async def release(self, session: QuerySessionAsync) -> None:
91
self._queue.put_nowait((1, session))
ydb/query/pool.py
@@ -79,6 +79,7 @@ def acquire(self, timeout: float) -> QuerySessionSync:
79
if finish - start > timeout:
80
session.delete()
81
raise issues.SessionPoolEmpty("Timeout on acquire session")
82
+
83
self._current_size += 1
84
0 commit comments