diff --git a/clients/python/fdclient/client.py b/clients/python/fdclient/client.py index 8c8bda5..d9f0327 100644 --- a/clients/python/fdclient/client.py +++ b/clients/python/fdclient/client.py @@ -15,8 +15,6 @@ import time import json -import concurrent.futures as futures - class FDClient: def __init__(self, server_url, compression=True, request_timeout=None): @@ -67,15 +65,6 @@ def _decompressor(self): self.local_storage.decompressor = zstandard.ZstdDecompressor() return self.local_storage.decompressor - @property - def _thread_pool_executor(self): - if ( - not hasattr(self.local_storage, "thread_pool_executor") - or self.local_storage.thread_pool_executor is None - ): - self.local_storage.thread_pool_executor = futures.ThreadPoolExecutor(32) - return self.local_storage.thread_pool_executor - @property def _decompressor(self): if self.compression is False: @@ -137,21 +126,6 @@ def infer(self, data, unique_id=None, is_async=False): def infer_async(self, data, unique_id=None): return self.infer(data, unique_id, is_async=True) - def infer_background(self, data, unique_id=None): - return self._thread_pool_executor.submit(self.infer, data, unique_id) - - def infer_background_multiple(self, data_list, unique_ids=None): - return [ - self.infer_background(data, unique_ids[i] if unique_ids else None) - for i, data in enumerate(data_list) - ] - - def __close__(self): - self._thread_pool_executor.shutdown(wait=False, cancel_futures=True) - - def __del__(self): - self.__close__() - if __name__ == "__main__": client = FDClient("http://localhost:8080") diff --git a/clients/python/setup.py b/clients/python/setup.py index 50b07d7..de433ee 100644 --- a/clients/python/setup.py +++ b/clients/python/setup.py @@ -18,7 +18,7 @@ EMAIL = "praneeth@bpraneeth.com" AUTHOR = "BEDAPUDI PRANEETH" REQUIRES_PYTHON = ">=3.6.0" -VERSION = "3.0.5" +VERSION = "3.0.6" # What packages are required for this module to be executed? REQUIRED = ["zstandard", "requests", "msgpack"]