@@ -0,0 +1,661 @@
+# coding: utf-8%0A%0A%0Aimport atexit%0Aimport weakref%0Aimport unittest%0A%0Aimport kubernetes%0A%0A%0Aclass TestApiClient(unittest.TestCase):%0A%0A    def test_context_manager_closes_threadpool(self):%0A        with kubernetes.client.ApiClient() as client:%0A            self.assertIsNotNone(client.pool)%0A            pool_ref = weakref.ref(client._pool)%0A            self.assertIsNotNone(pool_ref())%0A        self.assertIsNone(pool_ref())%0A%0A    def test_atexit_closes_threadpool(self):%0A        client = kubernetes.client.ApiClient()%0A        self.assertIsNotNone(client.pool)%0A        self.assertIsNotNone(client._pool)%0A        atexit._run_exitfuncs()%0A        self.assertIsNone(client._pool)%0A

Add test to ensure kubernetes client threadpool is cleaned up