isort

Author: annalvova05

airbyte-integrations/connectors/source-tiktok-marketing/acceptance-test-docker.sh

@@ -13,4 +13,3 @@ docker run --rm -it \
     -v $(pwd):/test_input \
     airbyte/source-acceptance-test:latest \
     --acceptance-test-config /test_input
-

airbyte-integrations/connectors/source-tiktok-marketing/bootstrap.md

@@ -11,5 +11,3 @@ The basic entity is 'advertiser'. All other streams use this required parameter
 
 Dependent streams have required parameter advertiser_id.
 As cursor field this connector uses "modify_time" values. But endpoints don't provide any mechanism for correct data filtering and sorting thus for incremental sync this connector tries to load all data and to validate a cursor field value on own side.
-
-

airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/source.py

@@ -5,30 +5,21 @@
 from typing import Any, List, Mapping, Tuple
 
 from airbyte_cdk.logger import AirbyteLogger
-from airbyte_cdk.models import AdvancedAuth, AuthFlowType, ConnectorSpecification, OAuthConfigSpecification, SyncMode
+from airbyte_cdk.models import (AdvancedAuth, AuthFlowType,
+                                ConnectorSpecification,
+                                OAuthConfigSpecification, SyncMode)
 from airbyte_cdk.models.airbyte_protocol import DestinationSyncMode
 from airbyte_cdk.sources import AbstractSource
 from airbyte_cdk.sources.streams import Stream
 from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
 
-from .spec import (
-    CompleteOauthOutputSpecification,
-    CompleteOauthServerInputSpecification,
-    CompleteOauthServerOutputSpecification,
-    SourceTiktokMarketingSpec,
-)
-from .streams import (
-    DEFAULT_START_DATE,
-    AdGroups,
-    AdGroupsReports,
-    Ads,
-    AdsReports,
-    Advertisers,
-    AdvertisersReports,
-    Campaigns,
-    CampaignsReports,
-    ReportGranularity,
-)
+from .spec import (CompleteOauthOutputSpecification,
+                   CompleteOauthServerInputSpecification,
+                   CompleteOauthServerOutputSpecification,
+                   SourceTiktokMarketingSpec)
+from .streams import (DEFAULT_START_DATE, AdGroups, AdGroupsReports, Ads,
+                      AdsReports, Advertisers, AdvertisersReports, Campaigns,
+                      CampaignsReports, ReportGranularity)
 
 DOCUMENTATION_URL = "https://docs.airbyte.io/integrations/sources/tiktok-marketing"
 

airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/spec.py

@@ -8,6 +8,7 @@
 from typing import Union
 
 from jsonschema import RefResolver
+
 from pydantic import BaseModel, Field
 
 from .streams import DEFAULT_START_DATE, ReportGranularity

airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/streams.py

@@ -9,17 +9,20 @@
 from decimal import Decimal
 from enum import Enum
 from functools import total_ordering
-from typing import Any, Dict, Iterable, List, Mapping, MutableMapping, Optional, Tuple, TypeVar, Union
+from typing import (Any, Dict, Iterable, List, Mapping, MutableMapping,
+                    Optional, Tuple, TypeVar, Union)
 
 import pendulum
-import pydantic
 import requests
+
+import pydantic
 from airbyte_cdk.models import SyncMode
 from airbyte_cdk.sources.streams.core import package_name_from_class
 from airbyte_cdk.sources.streams.http import HttpStream
 from airbyte_cdk.sources.streams.http.auth import NoAuth
 from airbyte_cdk.sources.utils.schema_helpers import ResourceSchemaLoader
-from airbyte_cdk.sources.utils.transform import TransformConfig, TypeTransformer
+from airbyte_cdk.sources.utils.transform import (TransformConfig,
+                                                 TypeTransformer)
 
 # TikTok Initial release date is September 2016
 DEFAULT_START_DATE = "2016-09-01"

airbyte-integrations/connectors/source-tiktok-marketing/unit_tests/unit_test.py

@@ -7,10 +7,12 @@
 from typing import Any, Dict, Iterable, List, Mapping, Tuple
 
 import pendulum
+
 import pytest
 import requests_mock
 import timeout_decorator
-from airbyte_cdk.sources.streams.http.exceptions import UserDefinedBackoffException
+from airbyte_cdk.sources.streams.http.exceptions import \
+    UserDefinedBackoffException
 from source_tiktok_marketing import SourceTiktokMarketing
 from source_tiktok_marketing.streams import Ads, Advertisers, JsonUpdatedState