Fix CI pipeline by adding conditional imports for async tests

- Added try/except blocks around httpx and async module imports
- Added @unittest.skipIf decorators to skip tests when httpx unavailable
- Ensures tests can be discovered by pytest without failing on import
- Fixes ImportError in CI when httpx extra dependencies not installed

Author: sergioteula

tests/amazon_creatorsapi/aio/api_test.py

@@ -3,26 +3,34 @@
 import unittest
 from unittest.mock import AsyncMock, MagicMock, patch
 
-from amazon_creatorsapi.aio import (
-    AsyncAmazonCreatorsApi,
-)
-from amazon_creatorsapi.errors import (
-    AssociateValidationError,
-    InvalidArgumentError,
-    ItemsNotFoundError,
-    RequestError,
-    TooManyRequestsError,
-)
-from creatorsapi_python_sdk.models.condition import Condition
-from creatorsapi_python_sdk.models.get_browse_nodes_resource import (
-    GetBrowseNodesResource,
-)
-from creatorsapi_python_sdk.models.get_items_resource import GetItemsResource
-from creatorsapi_python_sdk.models.get_variations_resource import GetVariationsResource
-from creatorsapi_python_sdk.models.search_items_resource import SearchItemsResource
-from creatorsapi_python_sdk.models.sort_by import SortBy
-
-
+try:
+    from amazon_creatorsapi.aio import (
+        AsyncAmazonCreatorsApi,
+    )
+    from amazon_creatorsapi.errors import (
+        AssociateValidationError,
+        InvalidArgumentError,
+        ItemsNotFoundError,
+        RequestError,
+        TooManyRequestsError,
+    )
+    from creatorsapi_python_sdk.models.condition import Condition
+    from creatorsapi_python_sdk.models.get_browse_nodes_resource import (
+        GetBrowseNodesResource,
+    )
+    from creatorsapi_python_sdk.models.get_items_resource import GetItemsResource
+    from creatorsapi_python_sdk.models.get_variations_resource import (
+        GetVariationsResource,
+    )
+    from creatorsapi_python_sdk.models.search_items_resource import SearchItemsResource
+    from creatorsapi_python_sdk.models.sort_by import SortBy
+
+    HTTPX_AVAILABLE = True
+except ImportError:
+    HTTPX_AVAILABLE = False
+
+
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiInit(unittest.TestCase):
     """Tests for AsyncAmazonCreatorsApi initialization."""
 
@@ -117,6 +125,7 @@ def test_raises_error_for_invalid_version(
         self.assertIn("Supported versions are:", str(context.exception))
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiContextManager(unittest.IsolatedAsyncioTestCase):
     """Tests for AsyncAmazonCreatorsApi async context manager."""
 
@@ -160,6 +169,7 @@ async def test_context_manager_exit_without_client(
         await api.__aexit__(None, None, None)
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiGetItems(unittest.IsolatedAsyncioTestCase):
     """Tests for get_items() method."""
 
@@ -317,6 +327,7 @@ async def test_get_items_with_optional_params(
         self.assertEqual(len(items), 1)
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiSearchItems(unittest.IsolatedAsyncioTestCase):
     """Tests for search_items() method."""
 
@@ -425,6 +436,7 @@ async def test_search_items_without_keywords(
         self.assertIn("browseNodeId", str(call_args))
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiErrorHandling(unittest.IsolatedAsyncioTestCase):
     """Tests for error handling."""
 
@@ -525,6 +537,7 @@ async def test_handles_invalid_associate_error(
                 await api.get_items(["B0DLFMFBJW"])
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiThrottling(unittest.IsolatedAsyncioTestCase):
     """Tests for throttling mechanism."""
 
@@ -570,6 +583,7 @@ async def test_throttling_waits_between_requests(
         self.assertTrue(mock_sleep.called)
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiGetVariations(unittest.IsolatedAsyncioTestCase):
     """Tests for get_variations() method."""
 
@@ -721,6 +735,7 @@ async def test_get_variations_not_found(
                 await api.get_variations("B0DLFMFBJV")
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncAmazonCreatorsApiGetBrowseNodes(unittest.IsolatedAsyncioTestCase):
     """Tests for get_browse_nodes() method."""
 

tests/amazon_creatorsapi/aio/auth_test.py

@@ -4,18 +4,24 @@
 import unittest
 from unittest.mock import AsyncMock, MagicMock, patch
 
-import httpx
+try:
+    import httpx
 
-from amazon_creatorsapi.aio.auth import (
-    GRANT_TYPE,
-    SCOPE,
-    TOKEN_EXPIRATION_BUFFER,
-    VERSION_ENDPOINTS,
-    AsyncOAuth2TokenManager,
-)
-from amazon_creatorsapi.errors import AuthenticationError
+    from amazon_creatorsapi.aio.auth import (
+        GRANT_TYPE,
+        SCOPE,
+        TOKEN_EXPIRATION_BUFFER,
+        VERSION_ENDPOINTS,
+        AsyncOAuth2TokenManager,
+    )
+    from amazon_creatorsapi.errors import AuthenticationError
 
+    HTTPX_AVAILABLE = True
+except ImportError:
+    HTTPX_AVAILABLE = False
 
+
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncOAuth2TokenManagerInit(unittest.TestCase):
     """Tests for AsyncOAuth2TokenManager initialization."""
 
@@ -76,6 +82,7 @@ def test_with_invalid_version(self) -> None:
         self.assertIn("Unsupported version", str(context.exception))
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncOAuth2TokenManagerIsTokenValid(unittest.TestCase):
     """Tests for is_token_valid() method."""
 
@@ -102,6 +109,7 @@ def test_returns_true_when_token_valid(self) -> None:
         self.assertTrue(manager.is_token_valid())
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncOAuth2TokenManagerClearToken(unittest.TestCase):
     """Tests for clear_token() method."""
 
@@ -117,6 +125,7 @@ def test_clears_token_and_expiration(self) -> None:
         self.assertIsNone(manager._expires_at)
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncOAuth2TokenManagerGetToken(unittest.IsolatedAsyncioTestCase):
     """Tests for get_token() method."""
 
@@ -188,6 +197,7 @@ async def test_refreshes_token_when_expired(
         self.assertIsNotNone(manager._expires_at)
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncOAuth2TokenManagerRefreshToken(unittest.IsolatedAsyncioTestCase):
     """Tests for refresh_token() method."""
 

tests/amazon_creatorsapi/aio/client_test.py

@@ -5,14 +5,20 @@
 import unittest
 from unittest.mock import AsyncMock, MagicMock, patch
 
-from amazon_creatorsapi.aio.client import (
-    DEFAULT_HOST,
-    DEFAULT_TIMEOUT,
-    AsyncHttpClient,
-    AsyncHttpResponse,
-)
+try:
+    from amazon_creatorsapi.aio.client import (
+        DEFAULT_HOST,
+        DEFAULT_TIMEOUT,
+        AsyncHttpClient,
+        AsyncHttpResponse,
+    )
+
+    HTTPX_AVAILABLE = True
+except ImportError:
+    HTTPX_AVAILABLE = False
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncHttpClient(unittest.IsolatedAsyncioTestCase):
     """Tests for AsyncHttpClient."""
 
@@ -112,6 +118,7 @@ async def test_post_with_context_manager(self, mock_client_cls: MagicMock) -> No
             mock_client_instance.post.assert_called_once()
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncHttpResponse(unittest.TestCase):
     """Tests for AsyncHttpResponse."""
 
@@ -123,6 +130,7 @@ def test_json_parsing(self) -> None:
         self.assertEqual(response.json(), {"foo": "bar"})
 
 
+@unittest.skipIf(not HTTPX_AVAILABLE, "httpx not installed")
 class TestAsyncModuleInit(unittest.TestCase):
     """Test async module initialization logic."""
 

tests/amazon_creatorsapi/aio/integration_test.py

@@ -11,8 +11,13 @@
 
 from dotenv import load_dotenv
 
-from amazon_creatorsapi.aio import AsyncAmazonCreatorsApi
-from amazon_creatorsapi.errors import ItemsNotFoundError
+try:
+    from amazon_creatorsapi.aio import AsyncAmazonCreatorsApi
+    from amazon_creatorsapi.errors import ItemsNotFoundError
+
+    HTTPX_AVAILABLE = True
+except ImportError:
+    HTTPX_AVAILABLE = False
 
 if TYPE_CHECKING:
     from creatorsapi_python_sdk.models.browse_node import BrowseNode
@@ -180,7 +185,7 @@ async def _run_api_setup() -> dict[str, object]:
 
 # Module-level cache - run setup once when module is loaded (only if credentials exist)
 _cached_data: dict[str, object] = {}
-if has_api_credentials():
+if has_api_credentials() and HTTPX_AVAILABLE:
     _cached_data = asyncio.run(_run_api_setup())