Skip to content

Commit ad1b4c1

Browse files
committed
Remove connection from pool before waiting for results
1 parent 3e31475 commit ad1b4c1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/aio/connection.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -239,12 +239,12 @@ async def close(self, grace: float = None):
239239

240240
self.closing = True
241241

242-
if self.calls:
243-
await asyncio.wait(self.calls.values(), timeout=grace)
244-
245242
for callback in self._cleanup_callbacks:
246243
callback(self)
247244

245+
if self.calls:
246+
await asyncio.wait(self.calls.values(), timeout=grace)
247+
248248
await self.destroy()
249249

250250
async def __aenter__(self):

0 commit comments

Comments
 (0)