Skip to content

Commit e538b8d

Browse files
committed
add tableclient destructors
1 parent f5e568e commit e538b8d

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

ydb/aio/table.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,10 @@ def __init__(self, driver, table_client_settings=None):
145145
super().__init__(driver=driver, table_client_settings=table_client_settings)
146146
self._pool: SessionPool = SessionPool(self._driver, 10)
147147

148+
def __del__(self):
149+
if not self._pool._terminating:
150+
asyncio.get_running_loop.call_soon(self._pool.stop)
151+
148152
def session(self):
149153
return Session(self._driver, self._table_client_settings)
150154

ydb/table.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1199,6 +1199,9 @@ def __init__(self, driver, table_client_settings=None):
11991199
super().__init__(driver=driver, table_client_settings=table_client_settings)
12001200
self._pool: SessionPool = SessionPool(self._driver, 10)
12011201

1202+
def __del__(self):
1203+
self._pool.close()
1204+
12021205
def async_scan_query(self, query, parameters=None, settings=None):
12031206
# type: (ydb.ScanQuery, tuple, ydb.BaseRequestSettings) -> ydb.AsyncResponseIterator
12041207
request = _scan_query_request_factory(query, parameters, settings)

0 commit comments

Comments
 (0)