Skip to content

Commit f92e9df

Browse files
committed
update
Signed-off-by: 0oshowero0 <o0shower0o@outlook.com>
1 parent ae0dcb2 commit f92e9df

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

transfer_queue/client.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -837,6 +837,8 @@ def wrapper(*args, **kwargs):
837837

838838
return wrapper
839839

840+
# Bind internal sync wrappers. Public methods are defined explicitly below
841+
# to ensure proper type hints and documentation.
840842
self._put = _make_sync(self.async_put)
841843
self._get_meta = _make_sync(self.async_get_meta)
842844
self._get_data = _make_sync(self.async_get_data)
@@ -1004,11 +1006,6 @@ def get_partition_list(
10041006
"""
10051007
return self._get_partition_list()
10061008

1007-
def close(self):
1008-
"""Close the client and cleanup resources including the executor."""
1009-
if hasattr(self, "_executor"):
1010-
self._executor.shutdown(wait=True)
1011-
10121009

10131010
def process_zmq_server_info(
10141011
handlers: dict[Any, Union["TransferQueueController", "TransferQueueStorageManager", "SimpleStorageUnit"]]

0 commit comments

Comments
 (0)