Auto-fix lint and format issues

Author: octavia-squidington-iii

airbyte_cdk/sources/declarative/extractors/record_filter.py

@@ -14,8 +14,8 @@
     RecordFilter as RecordFilterModel,
 )
 from airbyte_cdk.sources.declarative.parsers.component_constructor import (
-    ComponentConstructor,
     AdditionalFlags,
+    ComponentConstructor,
 )
 from airbyte_cdk.sources.types import Config, Record, StreamSlice, StreamState
 

airbyte_cdk/sources/declarative/parsers/component_constructor.py

@@ -7,12 +7,11 @@
 
 from pydantic.v1 import BaseModel
 
-from airbyte_cdk.sources.message import MessageRepository
+from airbyte_cdk.sources.connector_state_manager import ConnectorStateManager
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import ValueType
+from airbyte_cdk.sources.message import MessageRepository
 from airbyte_cdk.sources.types import Config
 
-from airbyte_cdk.sources.connector_state_manager import ConnectorStateManager
-
 M = TypeVar("M", bound=BaseModel)
 
 

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -448,8 +448,8 @@
     ZipfileDecoder as ZipfileDecoderModel,
 )
 from airbyte_cdk.sources.declarative.parsers.component_constructor import (
-    ComponentConstructor,
     AdditionalFlags,
+    ComponentConstructor,
 )
 from airbyte_cdk.sources.declarative.parsers.custom_code_compiler import (
     COMPONENTS_MODULE_NAME,

airbyte_cdk/sources/declarative/requesters/query_properties/query_properties.py

@@ -1,20 +1,20 @@
 # Copyright (c) 2025 Airbyte, Inc., all rights reserved.
 
 from dataclasses import InitVar, dataclass
-from typing import Any, Iterable, List, Mapping, Optional, Union, Callable
+from typing import Any, Callable, Iterable, List, Mapping, Optional, Union
 
-from airbyte_cdk.sources.declarative.requesters.query_properties import (
-    PropertiesFromEndpoint,
-    PropertyChunking,
-)
-from airbyte_cdk.sources.types import Config, StreamSlice
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
     QueryProperties as QueryPropertiesModel,
 )
 from airbyte_cdk.sources.declarative.parsers.component_constructor import (
-    ComponentConstructor,
     AdditionalFlags,
+    ComponentConstructor,
+)
+from airbyte_cdk.sources.declarative.requesters.query_properties import (
+    PropertiesFromEndpoint,
+    PropertyChunking,
 )
+from airbyte_cdk.sources.types import Config, StreamSlice
 
 
 @dataclass

airbyte_cdk/sources/declarative/retrievers/simple_retriever.py

@@ -10,6 +10,7 @@
 from typing import (
     Any,
     Callable,
+    Dict,
     Iterable,
     List,
     Mapping,
@@ -18,73 +19,72 @@
     Set,
     Tuple,
     Union,
-    Dict,
     cast,
 )
 
 import requests
+from pydantic import BaseModel
+from requests import Response
 from typing_extensions import deprecated
 
 from airbyte_cdk.models import AirbyteMessage
+from airbyte_cdk.sources.declarative.decoders import JsonDecoder
 from airbyte_cdk.sources.declarative.extractors.http_selector import HttpSelector
-from airbyte_cdk.sources.declarative.incremental import ResumableFullRefreshCursor
+from airbyte_cdk.sources.declarative.incremental import (
+    DatetimeBasedCursor,
+    ResumableFullRefreshCursor,
+)
 from airbyte_cdk.sources.declarative.incremental.declarative_cursor import DeclarativeCursor
 from airbyte_cdk.sources.declarative.interpolation import InterpolatedString
-from airbyte_cdk.sources.declarative.partition_routers.single_partition_router import (
-    SinglePartitionRouter,
-)
-from airbyte_cdk.sources.declarative.requesters.paginators.no_pagination import NoPagination
-from airbyte_cdk.sources.declarative.requesters.paginators.paginator import Paginator
-from airbyte_cdk.sources.declarative.requesters.query_properties import QueryProperties
-from airbyte_cdk.sources.declarative.requesters.request_options import (
-    DefaultRequestOptionsProvider,
-    RequestOptionsProvider,
-)
-from airbyte_cdk.sources.declarative.requesters.requester import Requester
-from airbyte_cdk.sources.declarative.retrievers.retriever import Retriever
-from airbyte_cdk.sources.declarative.stream_slicers.stream_slicer import StreamSlicer
-from airbyte_cdk.sources.http_logger import format_http_message
-from airbyte_cdk.sources.source import ExperimentalClassWarning
-from airbyte_cdk.sources.streams.core import StreamData
-from airbyte_cdk.sources.types import Config, Record, StreamSlice, StreamState
-from airbyte_cdk.utils.mapping_helpers import combine_mappings
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
-    SimpleRetriever as SimpleRetrieverModel,
-)
-from airbyte_cdk.sources.declarative.parsers.component_constructor import (
-    ComponentConstructor,
-    AdditionalFlags,
+    CustomIncrementalSync as CustomIncrementalSyncModel,
 )
-from airbyte_cdk.sources.declarative.transformations import RecordTransformation
-from airbyte_cdk.sources.declarative.decoders import JsonDecoder
-from pydantic import BaseModel
-from airbyte_cdk.sources.declarative.retrievers.file_uploader import DefaultFileUploader
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
-    IncrementingCountCursor as IncrementingCountCursorModel,
+    CustomRequester as CustomRequesterModel,
 )
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
     DatetimeBasedCursor as DatetimeBasedCursorModel,
 )
-
-from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
-    CustomIncrementalSync as CustomIncrementalSyncModel,
-)
-from requests import Response
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
     HttpRequester as HttpRequesterModel,
 )
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
-    CustomRequester as CustomRequesterModel,
+    IncrementingCountCursor as IncrementingCountCursorModel,
 )
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
     QueryProperties as QueryPropertiesModel,
 )
-from airbyte_cdk.sources.declarative.requesters.query_properties import QueryProperties
-from airbyte_cdk.sources.declarative.incremental import DatetimeBasedCursor
+from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
+    SimpleRetriever as SimpleRetrieverModel,
+)
 from airbyte_cdk.sources.declarative.models.declarative_component_schema import (
     SubstreamPartitionRouter as SubstreamPartitionRouterModel,
 )
+from airbyte_cdk.sources.declarative.parsers.component_constructor import (
+    AdditionalFlags,
+    ComponentConstructor,
+)
+from airbyte_cdk.sources.declarative.partition_routers.single_partition_router import (
+    SinglePartitionRouter,
+)
+from airbyte_cdk.sources.declarative.requesters.paginators.no_pagination import NoPagination
+from airbyte_cdk.sources.declarative.requesters.paginators.paginator import Paginator
+from airbyte_cdk.sources.declarative.requesters.query_properties import QueryProperties
+from airbyte_cdk.sources.declarative.requesters.request_options import (
+    DefaultRequestOptionsProvider,
+    RequestOptionsProvider,
+)
+from airbyte_cdk.sources.declarative.requesters.requester import Requester
+from airbyte_cdk.sources.declarative.retrievers.file_uploader import DefaultFileUploader
+from airbyte_cdk.sources.declarative.retrievers.retriever import Retriever
 from airbyte_cdk.sources.declarative.stream_slicers import StreamSlicerTestReadDecorator
+from airbyte_cdk.sources.declarative.stream_slicers.stream_slicer import StreamSlicer
+from airbyte_cdk.sources.declarative.transformations import RecordTransformation
+from airbyte_cdk.sources.http_logger import format_http_message
+from airbyte_cdk.sources.source import ExperimentalClassWarning
+from airbyte_cdk.sources.streams.core import StreamData
+from airbyte_cdk.sources.types import Config, Record, StreamSlice, StreamState
+from airbyte_cdk.utils.mapping_helpers import combine_mappings
 
 FULL_REFRESH_SYNC_COMPLETE_KEY = "__ab_full_refresh_sync_complete"