feat: avoid creating unused ThreadPools

openapi/python-api_client.py.patch

@@ -0,0 +1,42 @@
+--- a/kubernetes/client/api_client.py
++++ b/kubernetes/client/api_client.py
+@@ -58,13 +58,15 @@ class ApiClient(object):
+         'datetime': datetime,
+         'object': object,
+     }
++    _pool = None
+
+-    def __init__(self, configuration=None, header_name=None, header_value=None, cookie=None):
++    def __init__(self, configuration=None, header_name=None, header_value=None,
++                 cookie=None, pool_threads=None):
+         if configuration is None:
+             configuration = Configuration()
+         self.configuration = configuration
++        self.pool_threads = pool_threads
+
+-        self.pool = ThreadPool()
+         self.rest_client = RESTClientObject(configuration)
+         self.default_headers = {}
+         if header_name is not None:
+@@ -74,8 +76,19 @@ class ApiClient(object):
+         self.user_agent = 'Swagger-Codegen/8.0.0-snapshot/python'
+
+     def __del__(self):
+-        self.pool.close()
+-        self.pool.join()
++        if self._pool:
++            self._pool.close()
++            self._pool.join()
++            self._pool = None
++
++    @property
++    def pool(self):
++        """Create thread pool on first request
++         avoids instantiating unused threadpool for blocking clients.
++        """
++        if self._pool is None:
++            self._pool = ThreadPool(self.pool_threads)
++        return self._pool
+
+     @property
+     def user_agent(self):

openapi/python-asyncio-api_client.py.patch

@@ -0,0 +1,27 @@
+61a62
+>     _pool = None
+64c65
+<                  cookie=None):
+---
+>                  cookie=None, pool_threads=None):
+67a69
+>         self.pool_threads = pool_threads
+69d70
+<         self.pool = ThreadPool()
+79,80c80,92
+<         self.pool.close()
+<         self.pool.join()
+---
+>         if self._pool:
+>             self._pool.close()
+>             self._pool.join()
+>             self._pool = None
+> 
+>     @property
+>     def pool(self):
+>         """Create thread pool on first request
+>          avoids instantiating unused threadpool for blocking clients.
+>         """
+>         if self._pool is None:
+>             self._pool = ThreadPool(self.pool_threads)
+>         return self._pool

openapi/python-asyncio.sh

@@ -82,6 +82,9 @@ if [ ${PACKAGE_NAME} == "client" ]; then
   find "${OUTPUT_DIR}/client/" -type f -name \*.py -exec sed -i "s/async parameter/async_req parameter/g" {} +
   find "${OUTPUT_DIR}/client/" -type f -name \*.py -exec sed -i "s/if not async/if not async_req/g" {} +
 
+  # workaround https://github.com/swagger-api/swagger-codegen/pull/8061 (thread pool only on demand)
+  patch "${OUTPUT_DIR}/client/api_client.py" "${SCRIPT_ROOT}/python-asyncio-api_client.py.patch"
+
   # fix imports
   find "${OUTPUT_DIR}/client/" -type f -name \*.py -exec sed -i 's/import client\./import kubernetes_asyncio.client./g' {} +
   find "${OUTPUT_DIR}/client/" -type f -name \*.py -exec sed -i 's/from client/from kubernetes_asyncio.client/g' {} +

openapi/python.sh

@@ -60,6 +60,9 @@ find "${OUTPUT_DIR}/${PACKAGE_NAME}/" -type f -name \*.py -exec sed -i "s/'async
 sed -i "s/if not async/if not async_req/g" "${OUTPUT_DIR}/${PACKAGE_NAME}/api_client.py"
 #
 
+# workaround https://github.com/swagger-api/swagger-codegen/pull/8061 (thread pool only on demand)
+patch "${OUTPUT_DIR}/${PACKAGE_NAME}/api_client.py" "${SCRIPT_ROOT}/python-api_client.py.patch"
+
 find "${OUTPUT_DIR}/test" -type f -name \*.py -exec sed -i 's/\bclient/kubernetes.client/g' {} +
 find "${OUTPUT_DIR}" -path "${OUTPUT_DIR}/base" -prune -o -type f -a -name \*.md -exec sed -i 's/\bclient/kubernetes.client/g' {} +
 find "${OUTPUT_DIR}" -path "${OUTPUT_DIR}/base" -prune -o -type f -a -name \*.md -exec sed -i 's/kubernetes.client-python/client-python/g' {} +