File tree Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -59,3 +59,7 @@ def __init__(
59
59
self .scheme_client = scheme .SchemeClient (self )
60
60
self .table_client = table .TableClient (self , config .table_client_settings )
61
61
self .topic_client = topic .TopicClientAsyncIO (self , config .topic_client_settings )
62
+
63
+ async def stop (self , timeout = 10 ):
64
+ await self .table_client ._pool .stop (timeout )
65
+ await super ().stop (timeout = timeout )
Original file line number Diff line number Diff line change @@ -282,3 +282,7 @@ def __init__(
282
282
self .scheme_client = scheme .SchemeClient (self )
283
283
self .table_client = table .TableClient (self , driver_config .table_client_settings )
284
284
self .topic_client = topic .TopicClient (self , driver_config .topic_client_settings )
285
+
286
+ def stop (self ):
287
+ self .table_client ._pool .stop ()
288
+ super ().stop ()
You can’t perform that action at this time.
0 commit comments