Skip to content

Commit 7e51e81

Browse files
committed
update tableclient destructor
1 parent a45ec48 commit 7e51e81

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

ydb/aio/table.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -154,8 +154,7 @@ def __init__(self, driver, table_client_settings=None):
154154
self._pool: Optional[SessionPool] = None
155155

156156
def __del__(self):
157-
if not self._pool._terminating:
158-
asyncio.get_running_loop.call_soon(self._stop_pool_if_needed)
157+
asyncio.get_running_loop.call_soon(self._stop_pool_if_needed)
159158

160159
def session(self):
161160
return Session(self._driver, self._table_client_settings)
@@ -181,7 +180,7 @@ def _init_pool_if_needed(self):
181180
self._pool = SessionPool(self._driver, 10)
182181

183182
async def _stop_pool_if_needed(self, timeout=10):
184-
if self._pool is not None:
183+
if self._pool is not None and not self._pool._terminating:
185184
await self._pool.stop(timeout=timeout)
186185

187186
async def create_table(

0 commit comments

Comments
 (0)