Lint fixes

Author: mateuszkuprowski

src/unstructured_client/_hooks/custom/auth_header_hook.py

@@ -17,6 +17,7 @@
 import httpx
 
 from unstructured_client._hooks.types import BeforeRequestContext, BeforeRequestHook
+from unstructured_client.auth._base import _ExchangeCallableBase
 
 
 class AuthHeaderBeforeRequestHook(BeforeRequestHook):
@@ -43,11 +44,8 @@ def _is_exchange_callable(security_source: object) -> bool:
         token-exchange callables.
 
         The SDK wraps a user-supplied callable into an internal factory and
-        attaches ``__wrapped_callable__`` to it (see ``sdk.py``). We import
-        the base class lazily to avoid any cycle at module load.
+        attaches ``__wrapped_callable__`` to it (see ``sdk.py``).
         """
-        from unstructured_client.auth._base import _ExchangeCallableBase
-
         if security_source is None:
             return False
 

src/unstructured_client/auth/_base.py

@@ -16,7 +16,6 @@
 
 from __future__ import annotations
 
-import asyncio
 import logging
 import random
 import threading

src/unstructured_client/auth/client_credentials.py

@@ -19,13 +19,14 @@
 from __future__ import annotations
 
 import asyncio
+import concurrent.futures
 import time
 from typing import Any, Dict, Optional
 
 import httpx
 
 from ._base import _ExchangeCallableBase
-from ._exceptions import InvalidCredentialError, TokenExchangeError
+from ._exceptions import TokenExchangeError
 
 
 class ClientCredentials(_ExchangeCallableBase):
@@ -254,14 +255,12 @@ def __call__(self) -> str:
         temporary loop via :func:`asyncio.run`.
         """
         try:
-            loop = asyncio.get_running_loop()
+            asyncio.get_running_loop()
         except RuntimeError:
             return asyncio.run(self.acquire())
 
         # Inside a running loop - offload to a worker thread that drives its
         # own event loop so we don't block the caller's loop on httpx IO.
-        import concurrent.futures
-
         def _run_in_new_loop() -> str:
             return asyncio.run(self.acquire())