style: Clean up unused imports and modernize type hints

- Remove unused imports from test file: json, ConcurrentDeclarativeSource, HttpMocker
- Remove unused global variables: _CONFIG, _MANIFEST
- Update Optional[Mapping[str, Any]] to Mapping[str, Any] | None per Python 3.10+ style
- All 6 unit tests pass locally

Co-Authored-By: AJ Steers <[email protected]>

Author: devin-ai-integration[bot]

airbyte_cdk/sources/declarative/schema/inferred_schema_loader.py

@@ -5,7 +5,7 @@
 from collections.abc import Mapping as ABCMapping
 from collections.abc import Sequence
 from dataclasses import InitVar, dataclass
-from typing import Any, Mapping, Optional
+from typing import Any, Mapping
 
 from airbyte_cdk.models import AirbyteRecordMessage
 from airbyte_cdk.sources.declarative.retrievers.retriever import Retriever
@@ -101,7 +101,7 @@ def get_json_schema(self) -> Mapping[str, Any]:
             if record_count >= self.record_sample_size:
                 break
 
-        inferred_schema: Optional[Mapping[str, Any]] = schema_inferrer.get_stream_schema(
+        inferred_schema: Mapping[str, Any] | None = schema_inferrer.get_stream_schema(
             self.stream_name
         )
 

unit_tests/sources/declarative/schema/test_inferred_schema_loader.py

@@ -2,78 +2,11 @@
 # Copyright (c) 2024 Airbyte, Inc., all rights reserved.
 #
 
-import json
 from unittest.mock import MagicMock
 
 import pytest
 
-from airbyte_cdk.sources.declarative.concurrent_declarative_source import (
-    ConcurrentDeclarativeSource,
-)
 from airbyte_cdk.sources.declarative.schema import InferredSchemaLoader
-from airbyte_cdk.test.mock_http import HttpMocker, HttpRequest, HttpResponse
-
-_CONFIG = {
-    "start_date": "2024-07-01T00:00:00.000Z",
-    "api_key": "test_api_key",
-}
-
-_MANIFEST = {
-    "version": "6.7.0",
-    "definitions": {
-        "users_stream": {
-            "type": "DeclarativeStream",
-            "name": "users",
-            "primary_key": [],
-            "retriever": {
-                "type": "SimpleRetriever",
-                "requester": {
-                    "type": "HttpRequester",
-                    "url_base": "https://api.test.com",
-                    "path": "/users",
-                    "http_method": "GET",
-                    "authenticator": {
-                        "type": "ApiKeyAuthenticator",
-                        "header": "apikey",
-                        "api_token": "{{ config['api_key'] }}",
-                    },
-                },
-                "record_selector": {
-                    "type": "RecordSelector",
-                    "extractor": {"type": "DpathExtractor", "field_path": []},
-                },
-                "paginator": {"type": "NoPagination"},
-            },
-            "schema_loader": {
-                "type": "InferredSchemaLoader",
-                "retriever": {
-                    "type": "SimpleRetriever",
-                    "requester": {
-                        "type": "HttpRequester",
-                        "url_base": "https://api.test.com",
-                        "path": "/users",
-                        "http_method": "GET",
-                        "authenticator": {
-                            "type": "ApiKeyAuthenticator",
-                            "header": "apikey",
-                            "api_token": "{{ config['api_key'] }}",
-                        },
-                    },
-                    "record_selector": {
-                        "type": "RecordSelector",
-                        "extractor": {"type": "DpathExtractor", "field_path": []},
-                    },
-                    "paginator": {"type": "NoPagination"},
-                },
-                "record_sample_size": 3,
-            },
-        },
-    },
-    "streams": [
-        "#/definitions/users_stream",
-    ],
-    "check": {"stream_names": ["users"]},
-}
 
 
 @pytest.fixture