isort & black for **/__init__.py

Author: natikgadzhi

airbyte-cdk/python/airbyte_cdk/__init__.py

@@ -2,10 +2,11 @@
 # Copyright (c) 2021 Airbyte, Inc., all rights reserved.
 #
 
+from importlib import metadata
+
 from .connector import AirbyteSpec, Connector
 from .entrypoint import AirbyteEntrypoint
 from .logger import AirbyteLogger
-from importlib import metadata
 
 __all__ = ["AirbyteEntrypoint", "AirbyteLogger", "AirbyteSpec", "Connector"]
 __version__ = metadata.version("airbyte_cdk")

airbyte-cdk/python/airbyte_cdk/sources/declarative/auth/__init__.py

@@ -2,10 +2,7 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 
-from airbyte_cdk.sources.declarative.auth.oauth import DeclarativeOauth2Authenticator
 from airbyte_cdk.sources.declarative.auth.jwt import JwtAuthenticator
+from airbyte_cdk.sources.declarative.auth.oauth import DeclarativeOauth2Authenticator
 
-__all__ = [
-    "DeclarativeOauth2Authenticator",
-    "JwtAuthenticator"
-]
+__all__ = ["DeclarativeOauth2Authenticator", "JwtAuthenticator"]

airbyte-cdk/python/airbyte_cdk/sources/streams/__init__.py

@@ -3,6 +3,6 @@
 #
 
 # Initialize Streams Package
-from .core import NO_CURSOR_STATE_KEY, IncrementalMixin, CheckpointMixin, Stream
+from .core import NO_CURSOR_STATE_KEY, CheckpointMixin, IncrementalMixin, Stream
 
 __all__ = ["NO_CURSOR_STATE_KEY", "IncrementalMixin", "CheckpointMixin", "Stream"]

airbyte-cdk/python/airbyte_cdk/sources/streams/checkpoint/__init__.py

@@ -1,6 +1,18 @@
 # Copyright (c) 2024 Airbyte, Inc., all rights reserved.
 
 
-from .checkpoint_reader import CheckpointMode, CheckpointReader, FullRefreshCheckpointReader, IncrementalCheckpointReader, ResumableFullRefreshCheckpointReader
+from .checkpoint_reader import (
+    CheckpointMode,
+    CheckpointReader,
+    FullRefreshCheckpointReader,
+    IncrementalCheckpointReader,
+    ResumableFullRefreshCheckpointReader,
+)
 
-__all__ = ["CheckpointMode", "CheckpointReader", "FullRefreshCheckpointReader", "IncrementalCheckpointReader", "ResumableFullRefreshCheckpointReader"]
+__all__ = [
+    "CheckpointMode",
+    "CheckpointReader",
+    "FullRefreshCheckpointReader",
+    "IncrementalCheckpointReader",
+    "ResumableFullRefreshCheckpointReader",
+]

airbyte-cdk/python/airbyte_cdk/test/mock_http/__init__.py

@@ -1,6 +1,6 @@
 from airbyte_cdk.test.mock_http.matcher import HttpRequestMatcher
+from airbyte_cdk.test.mock_http.mocker import HttpMocker
 from airbyte_cdk.test.mock_http.request import HttpRequest
 from airbyte_cdk.test.mock_http.response import HttpResponse
-from airbyte_cdk.test.mock_http.mocker import HttpMocker
 
 __all__ = ["HttpMocker", "HttpRequest", "HttpRequestMatcher", "HttpResponse"]

airbyte-cdk/python/unit_tests/__init__.py

@@ -2,5 +2,6 @@
 
 # Import the thing that needs to be imported to stop the tests from falling over
 from airbyte_cdk.sources.declarative.manifest_declarative_source import ManifestDeclarativeSource
+
 # "Use" the thing so that the linter doesn't complain
 placeholder = ManifestDeclarativeSource

airbyte-ci/connectors/connectors_qa/src/connectors_qa/checks/__init__.py

@@ -5,10 +5,4 @@
 from .packaging import ENABLED_CHECKS as PACKAGING_CHECKS
 from .security import ENABLED_CHECKS as SECURITY_CHECKS
 
-ENABLED_CHECKS = (
-    DOCUMENTATION_CHECKS
-    + METADATA_CORRECTNESS_CHECKS
-    + PACKAGING_CHECKS
-    + ASSETS_CHECKS
-    + SECURITY_CHECKS
-)
+ENABLED_CHECKS = DOCUMENTATION_CHECKS + METADATA_CORRECTNESS_CHECKS + PACKAGING_CHECKS + ASSETS_CHECKS + SECURITY_CHECKS

airbyte-ci/connectors/live-tests/src/live_tests/__init__.py

@@ -1,2 +1 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
-

airbyte-ci/connectors/live-tests/src/live_tests/debug/__init__.py

@@ -6,7 +6,5 @@
 
 import dagger
 
-DAGGER_EXEC_TIMEOUT = dagger.Timeout(
-    int(os.environ.get("DAGGER_EXEC_TIMEOUT", "3600"))
-)  # One hour by default
+DAGGER_EXEC_TIMEOUT = dagger.Timeout(int(os.environ.get("DAGGER_EXEC_TIMEOUT", "3600")))  # One hour by default
 DAGGER_CONFIG = dagger.Config(timeout=DAGGER_EXEC_TIMEOUT, log_output=sys.stderr)

airbyte-ci/connectors/pipelines/pipelines/__init__.py

@@ -6,6 +6,7 @@
 import logging
 import os
 from typing import Union
+
 from rich.logging import RichHandler
 
 from .helpers import sentry_utils
@@ -17,7 +18,9 @@
 logging.getLogger("httpx").setLevel(logging.WARNING)
 
 # RichHandler does not work great in the CI environment, so we use a StreamHandler instead
-logging_handler: Union[RichHandler, logging.StreamHandler] = RichHandler(rich_tracebacks=True) if "CI" not in os.environ else logging.StreamHandler()
+logging_handler: Union[RichHandler, logging.StreamHandler] = (
+    RichHandler(rich_tracebacks=True) if "CI" not in os.environ else logging.StreamHandler()
+)
 
 
 logging.basicConfig(

airbyte-integrations/bases/connector-acceptance-test/connector_acceptance_test/tests/__init__.py

@@ -2,8 +2,17 @@
 # Copyright (c) 2021 Airbyte, Inc., all rights reserved.
 #
 
-from .test_core import TestBasicRead, TestConnection, TestConnectorAttributes, TestDiscovery, TestSpec, TestConnectorDocumentation
+from .test_core import TestBasicRead, TestConnection, TestConnectorAttributes, TestConnectorDocumentation, TestDiscovery, TestSpec
 from .test_full_refresh import TestFullRefresh
 from .test_incremental import TestIncremental
 
-__all__ = ["TestSpec", "TestBasicRead", "TestConnection", "TestConnectorAttributes", "TestDiscovery", "TestFullRefresh", "TestIncremental", "TestConnectorDocumentation"]
+__all__ = [
+    "TestSpec",
+    "TestBasicRead",
+    "TestConnection",
+    "TestConnectorAttributes",
+    "TestDiscovery",
+    "TestFullRefresh",
+    "TestIncremental",
+    "TestConnectorDocumentation",
+]

airbyte-integrations/connectors/source-amazon-ads/source_amazon_ads/schemas/__init__.py

@@ -2,18 +2,9 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 from .attribution_report import AttributionReportModel
-from .common import (
-    CatalogModel,
-    Keywords,
-    MetricsReport,
-    NegativeKeywords,
-    Portfolio
-)
+from .common import CatalogModel, Keywords, MetricsReport, NegativeKeywords, Portfolio
 from .profile import Profile
-from .sponsored_brands import (
-    BrandsAdGroup,
-    BrandsCampaign,
-)
+from .sponsored_brands import BrandsAdGroup, BrandsCampaign
 from .sponsored_display import DisplayAdGroup, DisplayBudgetRules, DisplayCampaign, DisplayCreatives, DisplayProductAds, DisplayTargeting
 from .sponsored_products import (
     ProductAd,
@@ -24,7 +15,7 @@
     ProductTargeting,
     SponsoredProductCampaignNegativeKeywordsModel,
     SponsoredProductKeywordsModel,
-    SponsoredProductNegativeKeywordsModel
+    SponsoredProductNegativeKeywordsModel,
 )
 
 __all__ = [
@@ -52,5 +43,5 @@
     "AttributionReportModel",
     "SponsoredProductCampaignNegativeKeywordsModel",
     "SponsoredProductKeywordsModel",
-    "SponsoredProductNegativeKeywordsModel"
+    "SponsoredProductNegativeKeywordsModel",
 ]

airbyte-integrations/connectors/source-amazon-ads/source_amazon_ads/streams/__init__.py

@@ -16,11 +16,7 @@
     SponsoredDisplayReportStream,
     SponsoredProductsReportStream,
 )
-from .sponsored_brands import (
-    SponsoredBrandsAdGroups,
-    SponsoredBrandsCampaigns,
-    SponsoredBrandsKeywords
-)
+from .sponsored_brands import SponsoredBrandsAdGroups, SponsoredBrandsCampaigns, SponsoredBrandsKeywords
 from .sponsored_display import (
     SponsoredDisplayAdGroups,
     SponsoredDisplayBudgetRules,

airbyte-integrations/connectors/source-amazon-ads/unit_tests/integrations/ad_requests/__init__.py

@@ -1,11 +1,11 @@
+from .attribution_report_request_builder import AttributionReportRequestBuilder
 from .oauth_request_builder import OAuthRequestBuilder
 from .profiles_request_builder import ProfilesRequestBuilder
-from .sponsored_brands_request_builder import SponsoredBrandsRequestBuilder
-from .attribution_report_request_builder import AttributionReportRequestBuilder
-from .sponsored_display_report_request_builder import SponsoredDisplayReportRequestBuilder
 from .report_check_status_request_builer import ReportCheckStatusRequestBuilder
 from .report_download_request_builder import ReportDownloadRequestBuilder
-from .sponsored_products_report_request_builder import SponsoredProductsReportRequestBuilder
-from .sponsored_brands_video_report_request_builder import SponsoredBrandsVideoReportRequestBuilder
 from .sponsored_brands_report_request_builder import SponsoredBrandsReportRequestBuilder
 from .sponsored_brands_report_v3_request_builder import SponsoredBrandsV3ReportRequestBuilder
+from .sponsored_brands_request_builder import SponsoredBrandsRequestBuilder
+from .sponsored_brands_video_report_request_builder import SponsoredBrandsVideoReportRequestBuilder
+from .sponsored_display_report_request_builder import SponsoredDisplayReportRequestBuilder
+from .sponsored_products_report_request_builder import SponsoredProductsReportRequestBuilder

airbyte-integrations/connectors/source-amazon-ads/unit_tests/integrations/ad_responses/__init__.py

@@ -1,8 +1,8 @@
-from .sponsored_brands_response_builder import SponsoredBrandsResponseBuilder
-from .profiles_response_builder import ProfilesResponseBuilder
-from .oauth_response_builder import OAuthResponseBuilder
-from .error_response_builder import ErrorResponseBuilder
 from .attribution_report_response_builder import AttributionReportResponseBuilder
-from .report_init_response_builder import ReportInitResponseBuilder
+from .error_response_builder import ErrorResponseBuilder
+from .oauth_response_builder import OAuthResponseBuilder
+from .profiles_response_builder import ProfilesResponseBuilder
 from .report_check_status_response_builder import ReportCheckStatusResponseBuilder
 from .report_download_response_builder import ReportDownloadResponseBuilder
+from .report_init_response_builder import ReportInitResponseBuilder
+from .sponsored_brands_response_builder import SponsoredBrandsResponseBuilder

airbyte-integrations/connectors/source-amazon-ads/unit_tests/integrations/ad_responses/records/__init__.py

@@ -1,7 +1,7 @@
-from .profiles_record_builder import ProfilesRecordBuilder
-from .sponsored_brands_record_builder import SponsoredBrandsRecordBuilder
-from .error_record_builder import ErrorRecordBuilder
 from .attribution_report_record_builder import AttributionReportRecordBuilder
-from .report_init_response_record_builder import ReportInitResponseRecordBuilder
+from .error_record_builder import ErrorRecordBuilder
+from .profiles_record_builder import ProfilesRecordBuilder
 from .report_check_status_record_builder import ReportCheckStatusRecordBuilder
 from .report_file_recod_builder import ReportFileRecordBuilder
+from .report_init_response_record_builder import ReportInitResponseRecordBuilder
+from .sponsored_brands_record_builder import SponsoredBrandsRecordBuilder

airbyte-integrations/connectors/source-amazon-ads/unit_tests/integrations/ad_responses/records/fields/__init__.py

@@ -1,2 +1,2 @@
-from .list_template_path import ListTemplatePath
 from .dict_template_path import DictTemplatePath
+from .list_template_path import ListTemplatePath

airbyte-integrations/connectors/source-hubspot/unit_tests/integrations/__init__.py

@@ -16,8 +16,8 @@
 from .config_builder import ConfigBuilder
 from .request_builders.api import CustomObjectsRequestBuilder, OAuthRequestBuilder, PropertiesRequestBuilder, ScopesRequestBuilder
 from .request_builders.streams import CRMStreamRequestBuilder, IncrementalCRMStreamRequestBuilder, WebAnalyticsRequestBuilder
-from .response_builder.helpers import RootHttpResponseBuilder
 from .response_builder.api import ScopesResponseBuilder
+from .response_builder.helpers import RootHttpResponseBuilder
 from .response_builder.streams import GenericResponseBuilder, HubspotStreamResponseBuilder