From 535d01a961df4d7c6ccfd17cce37e7cb5238981b Mon Sep 17 00:00:00 2001 From: n0rritt Date: Thu, 28 Oct 2021 12:12:51 +0200 Subject: [PATCH 1/6] Include requester and stats in tickets stream --- .../source-freshdesk/sample_files/configured_catalog.json | 6 ++++++ .../connectors/source-freshdesk/source_freshdesk/api.py | 7 ++++++- .../source-freshdesk/source_freshdesk/schemas/tickets.json | 6 ++++++ 3 files changed, 18 insertions(+), 1 deletion(-) diff --git a/airbyte-integrations/connectors/source-freshdesk/sample_files/configured_catalog.json b/airbyte-integrations/connectors/source-freshdesk/sample_files/configured_catalog.json index 6b3d9084958d9..959d3cc5ab5de 100644 --- a/airbyte-integrations/connectors/source-freshdesk/sample_files/configured_catalog.json +++ b/airbyte-integrations/connectors/source-freshdesk/sample_files/configured_catalog.json @@ -647,6 +647,12 @@ }, "description_text": { "type": "string" + }, + "requester": { + "type": "object" + }, + "stats": { + "type": "object" } } }, diff --git a/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py b/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py index 0c0f5fae90b50..b7907886c9b8f 100644 --- a/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py +++ b/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py @@ -264,7 +264,12 @@ class TicketsAPI(IncrementalStreamAPI): def list(self, fields: Sequence[str] = None) -> Iterator[dict]: """Iterate over entities""" - params = {"include": "description"} + includes = [ + "description", + "requester", + "stats" + ] + params = {"include": ",".join(includes)} yield from self.read(partial(self._api_get, url="tickets"), params=params) @staticmethod diff --git a/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/schemas/tickets.json b/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/schemas/tickets.json index a338b796e81d7..c232835267650 100644 --- a/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/schemas/tickets.json +++ b/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/schemas/tickets.json @@ -100,6 +100,12 @@ }, "description_text": { "type": "string" + }, + "requester": { + "type": "object" + }, + "stats": { + "type": "object" } } } From f9d829d604b5b3108f7f85ecb4b5a8b4fc90b8b7 Mon Sep 17 00:00:00 2001 From: n0rritt Date: Fri, 29 Oct 2021 11:12:54 +0200 Subject: [PATCH 2/6] Update documentation, rebase to lastest master state and bump version --- airbyte-integrations/connectors/source-freshdesk/CHANGELOG.md | 3 +++ airbyte-integrations/connectors/source-freshdesk/Dockerfile | 2 +- docs/integrations/sources/freshdesk.md | 1 + 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/airbyte-integrations/connectors/source-freshdesk/CHANGELOG.md b/airbyte-integrations/connectors/source-freshdesk/CHANGELOG.md index 56afe5e9c941c..5b2bc611b7124 100644 --- a/airbyte-integrations/connectors/source-freshdesk/CHANGELOG.md +++ b/airbyte-integrations/connectors/source-freshdesk/CHANGELOG.md @@ -1,5 +1,8 @@ # Changelog +## 0.2.8 +Include `requester` and `stats` fields in `tickets` stream + ## 0.2.7 Add start_date parameter to specification from which to start pulling data. diff --git a/airbyte-integrations/connectors/source-freshdesk/Dockerfile b/airbyte-integrations/connectors/source-freshdesk/Dockerfile index f4822e7c66222..5765f86e1e7e7 100644 --- a/airbyte-integrations/connectors/source-freshdesk/Dockerfile +++ b/airbyte-integrations/connectors/source-freshdesk/Dockerfile @@ -14,5 +14,5 @@ RUN pip install . ENV AIRBYTE_ENTRYPOINT "/airbyte/base.sh" -LABEL io.airbyte.version=0.2.7 +LABEL io.airbyte.version=0.2.8 LABEL io.airbyte.name=airbyte/source-freshdesk diff --git a/docs/integrations/sources/freshdesk.md b/docs/integrations/sources/freshdesk.md index 555bb133c8293..4a003ede7d233 100644 --- a/docs/integrations/sources/freshdesk.md +++ b/docs/integrations/sources/freshdesk.md @@ -53,5 +53,6 @@ Please read [How to find your API key](https://support.freshdesk.com/support/sol | Version | Date | Pull Request | Subject | | :--- | :--- | :--- | :--- | +| 0.2.8 | 2021-10-28 | [7486](https://github.com/airbytehq/airbyte/pull/7486) | Include "requester" and "stats" fields in "tickets" stream | | 0.2.7 | 2021-10-13 | [6442](https://github.com/airbytehq/airbyte/pull/6442) | Add start_date parameter to specification from which to start pulling data. | From b25a1c1cbbbaf9dd9fcc92231a71acdf76b3c3ab Mon Sep 17 00:00:00 2001 From: Marcos Marx Date: Mon, 15 Nov 2021 10:48:01 -0300 Subject: [PATCH 3/6] run format --- .../airbyte_cdk/models/airbyte_protocol.py | 2 +- .../ec4b9503-13cb-48ab-a4ab-6ade4be46567.json | 2 +- .../resources/seed/source_definitions.yaml | 2 +- .../models/airbyte_protocol.py | 2 +- .../destination_kvdb/writer.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source_amazon_seller_partner/auth.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../CockroachJdbcSourceOperations.java | 5 +++++ .../CockroachDbSourceDatatypeTest.java | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- ...ncryptSourceCertificateAcceptanceTest.java | 6 ++++-- .../Db2Source.java | 1 - .../Db2SourceOperations.java | 1 - .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source_drift/client/common.py | 4 ++-- .../source_facebook_marketing/source.py | 1 + .../unit_tests/test_async_job.py | 1 + .../integration_tests/acceptance.py | 2 +- .../source-freshdesk/source_freshdesk/api.py | 6 +----- .../integration_tests/acceptance.py | 2 +- .../integration_tests/integration_test.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source-hubspot/source_hubspot/api.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/dummy_test.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source_linkedin_ads/source.py | 12 +++++------ .../analytics_tests/test_merge_chunks.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/dummy_test.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source-s3/integration_tests/acceptance.py | 2 +- .../integration_test_abstract.py | 2 +- .../formats/csv_parser.py | 2 +- .../source_s3/source_files_abstract/spec.py | 2 +- .../source_s3/source_files_abstract/stream.py | 2 +- .../unit_tests/abstract_test_parser.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/integration_test.py | 2 +- .../source-shopify/source_shopify/auth.py | 2 +- .../source-shopify/source_shopify/source.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source_snapchat_marketing/source.py | 20 +++++++++---------- .../unit_tests/unit_test.py | 4 ++-- .../integration_tests/acceptance.py | 2 +- .../source-square/source_square/source.py | 18 ++++++++--------- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../source_tiktok_marketing/spec.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- .../integration_tests/integration_test.py | 4 ++-- .../source_zendesk_support/streams.py | 4 ++-- .../source_zendesk_talk/source.py | 1 + .../source_zendesk_talk/streams.py | 15 +++++++------- .../source-zuora/source_zuora/source.py | 10 +++++----- .../source_zuora/zuora_endpoint.py | 2 +- .../source-zuora/source_zuora/zuora_errors.py | 6 +++--- .../source-zuora/unit_tests/unit_test.py | 2 +- .../api/generated-api-html/index.html | 6 +++--- 105 files changed, 150 insertions(+), 147 deletions(-) diff --git a/airbyte-cdk/python/airbyte_cdk/models/airbyte_protocol.py b/airbyte-cdk/python/airbyte_cdk/models/airbyte_protocol.py index 0de561d5478db..ed89e1d7b4416 100644 --- a/airbyte-cdk/python/airbyte_cdk/models/airbyte_protocol.py +++ b/airbyte-cdk/python/airbyte_cdk/models/airbyte_protocol.py @@ -114,8 +114,8 @@ class AuthSpecification(BaseModel): class AuthFlowType(Enum): - oauth1_0 = "oauth1.0" oauth2_0 = "oauth2.0" + oauth1_0 = "oauth1.0" class OAuthConfigSpecification(BaseModel): diff --git a/airbyte-config/init/src/main/resources/config/STANDARD_SOURCE_DEFINITION/ec4b9503-13cb-48ab-a4ab-6ade4be46567.json b/airbyte-config/init/src/main/resources/config/STANDARD_SOURCE_DEFINITION/ec4b9503-13cb-48ab-a4ab-6ade4be46567.json index b58513a5abcf3..e79b48be69e05 100644 --- a/airbyte-config/init/src/main/resources/config/STANDARD_SOURCE_DEFINITION/ec4b9503-13cb-48ab-a4ab-6ade4be46567.json +++ b/airbyte-config/init/src/main/resources/config/STANDARD_SOURCE_DEFINITION/ec4b9503-13cb-48ab-a4ab-6ade4be46567.json @@ -2,7 +2,7 @@ "sourceDefinitionId": "ec4b9503-13cb-48ab-a4ab-6ade4be46567", "name": "Freshdesk", "dockerRepository": "airbyte/source-freshdesk", - "dockerImageTag": "0.2.7", + "dockerImageTag": "0.2.8", "documentationUrl": "https://docs.airbyte.io/integrations/sources/freshdesk", "icon": "freshdesk.svg" } diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml index 226ee2419a567..797a5068dfc49 100644 --- a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml @@ -158,7 +158,7 @@ - name: Freshdesk sourceDefinitionId: ec4b9503-13cb-48ab-a4ab-6ade4be46567 dockerRepository: airbyte/source-freshdesk - dockerImageTag: 0.2.7 + dockerImageTag: 0.2.8 documentationUrl: https://docs.airbyte.io/integrations/sources/freshdesk icon: freshdesk.svg sourceType: api diff --git a/airbyte-integrations/bases/airbyte-protocol/airbyte_protocol/models/airbyte_protocol.py b/airbyte-integrations/bases/airbyte-protocol/airbyte_protocol/models/airbyte_protocol.py index 0de561d5478db..ed89e1d7b4416 100644 --- a/airbyte-integrations/bases/airbyte-protocol/airbyte_protocol/models/airbyte_protocol.py +++ b/airbyte-integrations/bases/airbyte-protocol/airbyte_protocol/models/airbyte_protocol.py @@ -114,8 +114,8 @@ class AuthSpecification(BaseModel): class AuthFlowType(Enum): - oauth1_0 = "oauth1.0" oauth2_0 = "oauth2.0" + oauth1_0 = "oauth1.0" class OAuthConfigSpecification(BaseModel): diff --git a/airbyte-integrations/connectors/destination-kvdb/destination_kvdb/writer.py b/airbyte-integrations/connectors/destination-kvdb/destination_kvdb/writer.py index 06847d7273821..d446ee399df67 100644 --- a/airbyte-integrations/connectors/destination-kvdb/destination_kvdb/writer.py +++ b/airbyte-integrations/connectors/destination-kvdb/destination_kvdb/writer.py @@ -25,7 +25,7 @@ def __init__(self, client: KvDbClient): self.client = client def delete_stream_entries(self, stream_name: str): - """ Deletes all the records belonging to the input stream """ + """Deletes all the records belonging to the input stream""" keys_to_delete = [] for key in self.client.list_keys(prefix=f"{stream_name}__ab__"): keys_to_delete.append(key) diff --git a/airbyte-integrations/connectors/source-amazon-ads/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-amazon-ads/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-amazon-ads/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-amazon-ads/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/source_amazon_seller_partner/auth.py b/airbyte-integrations/connectors/source-amazon-seller-partner/source_amazon_seller_partner/auth.py index 64b27fe5095f5..b30ed7a8c52d0 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/source_amazon_seller_partner/auth.py +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/source_amazon_seller_partner/auth.py @@ -41,7 +41,7 @@ def __init__(self, service: str, aws_access_key_id: str, aws_secret_access_key: @staticmethod def _sign_msg(key: bytes, msg: str) -> bytes: - """ Sign message using key """ + """Sign message using key""" return hmac.new(key, msg.encode("utf-8"), hashlib.sha256).digest() def _get_authorization_header(self, prepared_request: requests.PreparedRequest) -> str: diff --git a/airbyte-integrations/connectors/source-amazon-sqs/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-amazon-sqs/integration_tests/acceptance.py index a1c52d74fe81e..4b6c44dfc6139 100644 --- a/airbyte-integrations/connectors/source-amazon-sqs/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-amazon-sqs/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-amplitude/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-amplitude/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-amplitude/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-amplitude/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-apify-dataset/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-apify-dataset/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-apify-dataset/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-apify-dataset/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-appsflyer/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-appsflyer/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-appsflyer/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-appsflyer/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-asana/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-asana/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-asana/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-asana/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-aws-cloudtrail/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-aws-cloudtrail/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-aws-cloudtrail/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-aws-cloudtrail/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-azure-table/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-azure-table/integration_tests/acceptance.py index a1c52d74fe81e..4b6c44dfc6139 100644 --- a/airbyte-integrations/connectors/source-azure-table/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-azure-table/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-bamboo-hr/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-bamboo-hr/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-bamboo-hr/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-bamboo-hr/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-bigcommerce/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-bigcommerce/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-bigcommerce/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-bigcommerce/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-bing-ads/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-bing-ads/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-bing-ads/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-bing-ads/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-cart/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-cart/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-cart/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-cart/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-chargebee/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-chargebee/integration_tests/acceptance.py index a1c52d74fe81e..4b6c44dfc6139 100644 --- a/airbyte-integrations/connectors/source-chargebee/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-chargebee/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-close-com/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-close-com/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-close-com/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-close-com/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-cockroachdb/src/main/java/io/airbyte/integrations/source/cockroachdb/CockroachJdbcSourceOperations.java b/airbyte-integrations/connectors/source-cockroachdb/src/main/java/io/airbyte/integrations/source/cockroachdb/CockroachJdbcSourceOperations.java index e24ef00a4caf5..bd63bf6e9faa3 100644 --- a/airbyte-integrations/connectors/source-cockroachdb/src/main/java/io/airbyte/integrations/source/cockroachdb/CockroachJdbcSourceOperations.java +++ b/airbyte-integrations/connectors/source-cockroachdb/src/main/java/io/airbyte/integrations/source/cockroachdb/CockroachJdbcSourceOperations.java @@ -1,3 +1,7 @@ +/* + * Copyright (c) 2021 Airbyte, Inc., all rights reserved. + */ + package io.airbyte.integrations.source.cockroachdb; import com.fasterxml.jackson.databind.JsonNode; @@ -64,4 +68,5 @@ private void putCockroachSpecialDataType(ResultSet resultSet, int index, ObjectN node.put(columnName, (Double) null); } } + } diff --git a/airbyte-integrations/connectors/source-cockroachdb/src/test-integration/java/io/airbyte/integrations/source/cockroachdb/CockroachDbSourceDatatypeTest.java b/airbyte-integrations/connectors/source-cockroachdb/src/test-integration/java/io/airbyte/integrations/source/cockroachdb/CockroachDbSourceDatatypeTest.java index bac0377247848..3df4886dd8686 100644 --- a/airbyte-integrations/connectors/source-cockroachdb/src/test-integration/java/io/airbyte/integrations/source/cockroachdb/CockroachDbSourceDatatypeTest.java +++ b/airbyte-integrations/connectors/source-cockroachdb/src/test-integration/java/io/airbyte/integrations/source/cockroachdb/CockroachDbSourceDatatypeTest.java @@ -313,7 +313,7 @@ protected void initTests() { .addNullExpectedValue() .build()); - // Time (04:05:06) would be represented like "1970-01-01T04:05:06Z" + // Time (04:05:06) would be represented like "1970-01-01T04:05:06Z" addDataTypeTestData( TestDataHolder.builder() .sourceType("timetz") diff --git a/airbyte-integrations/connectors/source-commercetools/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-commercetools/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-commercetools/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-commercetools/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-confluence/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-confluence/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-confluence/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-confluence/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-db2-strict-encrypt/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/Db2StrictEncryptSourceCertificateAcceptanceTest.java b/airbyte-integrations/connectors/source-db2-strict-encrypt/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/Db2StrictEncryptSourceCertificateAcceptanceTest.java index 3731c00630583..1d25d4784f08b 100644 --- a/airbyte-integrations/connectors/source-db2-strict-encrypt/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/Db2StrictEncryptSourceCertificateAcceptanceTest.java +++ b/airbyte-integrations/connectors/source-db2-strict-encrypt/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/Db2StrictEncryptSourceCertificateAcceptanceTest.java @@ -164,8 +164,10 @@ protected void tearDown(TestDestinationEnv testEnv) { /* Helpers */ private String getCertificate() throws IOException, InterruptedException { - // To enable SSL connection on the server, we need to generate self-signed certificates for the server and add them to the configuration. - // Then you need to enable SSL connection and specify on which port it will work. These changes will take effect after restart. + // To enable SSL connection on the server, we need to generate self-signed certificates for the + // server and add them to the configuration. + // Then you need to enable SSL connection and specify on which port it will work. These changes will + // take effect after restart. // The certificate for generating a user certificate has the extension *.arm. db.execInContainer("su", "-", "db2inst1", "-c", "gsk8capicmd_64 -keydb -create -db \"server.kdb\" -pw \"" + TEST_KEY_STORE_PASS + "\" -stash"); db.execInContainer("su", "-", "db2inst1", "-c", "gsk8capicmd_64 -cert -create -db \"server.kdb\" -pw \"" + TEST_KEY_STORE_PASS diff --git a/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2Source.java b/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2Source.java index 542a02cd1dab9..e8b4dc35f6e3d 100644 --- a/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2Source.java +++ b/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2Source.java @@ -8,7 +8,6 @@ import com.google.common.collect.ImmutableMap; import io.airbyte.commons.json.Jsons; import io.airbyte.db.jdbc.Db2JdbcStreamingQueryConfiguration; -import io.airbyte.db.jdbc.JdbcSourceOperations; import io.airbyte.integrations.base.IntegrationRunner; import io.airbyte.integrations.base.Source; import io.airbyte.integrations.source.jdbc.AbstractJdbcSource; diff --git a/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2SourceOperations.java b/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2SourceOperations.java index 29e55bfc25258..17800463f6833 100644 --- a/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2SourceOperations.java +++ b/airbyte-integrations/connectors/source-db2/src/main/java/io.airbyte.integrations.source.db2/Db2SourceOperations.java @@ -8,7 +8,6 @@ import com.fasterxml.jackson.databind.node.ObjectNode; import io.airbyte.commons.json.Jsons; import io.airbyte.db.jdbc.JdbcSourceOperations; -import java.sql.JDBCType; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Collections; diff --git a/airbyte-integrations/connectors/source-delighted/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-delighted/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-delighted/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-delighted/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-drift/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-drift/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-drift/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-drift/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-drift/source_drift/client/common.py b/airbyte-integrations/connectors/source-drift/source_drift/client/common.py index 0b84fca9d6774..0d24c753a9a99 100644 --- a/airbyte-integrations/connectors/source-drift/source_drift/client/common.py +++ b/airbyte-integrations/connectors/source-drift/source_drift/client/common.py @@ -74,7 +74,7 @@ def next_url_paginator(request, start_index: int = None, per_page: int = 100, pa def exception_from_code(code: int, message: str) -> Exception: - """ Map response code to exception class""" + """Map response code to exception class""" mapping = { 400: ValidationError, 401: AuthError, @@ -91,7 +91,7 @@ def exception_from_code(code: int, message: str) -> Exception: def _parsed_response(func): - """ Decorator to check response status and parse its body""" + """Decorator to check response status and parse its body""" @functools.wraps(func) def wrapper(*args, **kwargs): diff --git a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py index a7a97d3bbb0be..0a3dcdb33263a 100644 --- a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py +++ b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py @@ -1,6 +1,7 @@ # # Copyright (c) 2021 Airbyte, Inc., all rights reserved. # + import logging from datetime import datetime from typing import Any, List, Mapping, MutableMapping, Optional, Tuple, Type diff --git a/airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_async_job.py b/airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_async_job.py index f35d8d7596b3f..6bab56862fa87 100644 --- a/airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_async_job.py +++ b/airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_async_job.py @@ -1,6 +1,7 @@ # # Copyright (c) 2021 Airbyte, Inc., all rights reserved. # + import time import pendulum diff --git a/airbyte-integrations/connectors/source-file-secure/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-file-secure/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-file-secure/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-file-secure/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py b/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py index b7907886c9b8f..1b29f414e4993 100644 --- a/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py +++ b/airbyte-integrations/connectors/source-freshdesk/source_freshdesk/api.py @@ -264,11 +264,7 @@ class TicketsAPI(IncrementalStreamAPI): def list(self, fields: Sequence[str] = None) -> Iterator[dict]: """Iterate over entities""" - includes = [ - "description", - "requester", - "stats" - ] + includes = ["description", "requester", "stats"] params = {"include": ",".join(includes)} yield from self.read(partial(self._api_get, url="tickets"), params=params) diff --git a/airbyte-integrations/connectors/source-freshsales/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-freshsales/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-freshsales/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-freshsales/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-freshsales/integration_tests/integration_test.py b/airbyte-integrations/connectors/source-freshsales/integration_tests/integration_test.py index 2824cd4a16cdb..947827faf3111 100644 --- a/airbyte-integrations/connectors/source-freshsales/integration_tests/integration_test.py +++ b/airbyte-integrations/connectors/source-freshsales/integration_tests/integration_test.py @@ -4,5 +4,5 @@ def test_dummy_test(): - """ this is the dummy test to pass integration tests step """ + """this is the dummy test to pass integration tests step""" pass diff --git a/airbyte-integrations/connectors/source-freshservice/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-freshservice/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-freshservice/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-freshservice/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-gitlab/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-gitlab/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-gitlab/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-gitlab/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-google-ads/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-google-ads/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-google-ads/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-google-ads/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-google-directory/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-google-directory/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-google-directory/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-google-directory/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-google-sheets/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-google-sheets/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-google-sheets/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-google-sheets/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-greenhouse/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-greenhouse/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-greenhouse/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-greenhouse/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-harvest/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-harvest/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-harvest/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-harvest/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-hubspot/source_hubspot/api.py b/airbyte-integrations/connectors/source-hubspot/source_hubspot/api.py index 232bced93affd..61fecbe3633af 100644 --- a/airbyte-integrations/connectors/source-hubspot/source_hubspot/api.py +++ b/airbyte-integrations/connectors/source-hubspot/source_hubspot/api.py @@ -153,7 +153,7 @@ def _parse_and_handle_errors(response) -> Union[MutableMapping[str, Any], List[M message = response.json().get("message") if response.status_code == HTTPStatus.FORBIDDEN: - """ Once hit the forbidden endpoint, we return the error message from response. """ + """Once hit the forbidden endpoint, we return the error message from response.""" pass elif response.status_code in (HTTPStatus.UNAUTHORIZED, CLOUDFLARE_ORIGIN_DNS_ERROR): raise HubspotInvalidAuth(message, response=response) diff --git a/airbyte-integrations/connectors/source-jira/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-jira/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-jira/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-jira/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-klaviyo/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-klaviyo/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-klaviyo/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-klaviyo/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-klaviyo/integration_tests/dummy_test.py b/airbyte-integrations/connectors/source-klaviyo/integration_tests/dummy_test.py index 340e7431bc58d..6f3a10993a502 100644 --- a/airbyte-integrations/connectors/source-klaviyo/integration_tests/dummy_test.py +++ b/airbyte-integrations/connectors/source-klaviyo/integration_tests/dummy_test.py @@ -4,5 +4,5 @@ def test_dummy(): - """ This is just to fix customIntegration task in Gradle. It fails when pytest unable to find tests.""" + """This is just to fix customIntegration task in Gradle. It fails when pytest unable to find tests.""" assert True diff --git a/airbyte-integrations/connectors/source-kustomer-singer/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-kustomer-singer/integration_tests/acceptance.py index a1c52d74fe81e..4b6c44dfc6139 100644 --- a/airbyte-integrations/connectors/source-kustomer-singer/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-kustomer-singer/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-lemlist/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-lemlist/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-lemlist/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-lemlist/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-lever-hiring/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-lever-hiring/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-lever-hiring/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-lever-hiring/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-linkedin-ads/source_linkedin_ads/source.py b/airbyte-integrations/connectors/source-linkedin-ads/source_linkedin_ads/source.py index f5ad4b9efe477..389518dcfc238 100644 --- a/airbyte-integrations/connectors/source-linkedin-ads/source_linkedin_ads/source.py +++ b/airbyte-integrations/connectors/source-linkedin-ads/source_linkedin_ads/source.py @@ -33,11 +33,11 @@ def __init__(self, config: Dict): @property def accounts(self): - """ Property to return the list of the user Account Ids from input """ + """Property to return the list of the user Account Ids from input""" return ",".join(map(str, self.config.get("account_ids"))) def path(self, **kwargs) -> str: - """ Returns the API endpoint path for stream, from `endpoint` class attribute. """ + """Returns the API endpoint path for stream, from `endpoint` class attribute.""" return self.endpoint def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, Any]]: @@ -112,11 +112,11 @@ def primary_slice_key(self) -> str: @abstractproperty def parent_stream(self) -> object: - """ Defines the parrent stream for slicing, the class object should be provided. """ + """Defines the parrent stream for slicing, the class object should be provided.""" @property def state_checkpoint_interval(self) -> Optional[int]: - """ Define the checkpoint from the records output size. """ + """Define the checkpoint from the records output size.""" return super().records_limit def get_updated_state(self, current_stream_state: MutableMapping[str, Any], latest_record: Mapping[str, Any]) -> Mapping[str, Any]: @@ -146,7 +146,7 @@ def request_params(self, stream_state: Mapping[str, Any], stream_slice: Mapping[ return params def filter_records_newer_than_state(self, stream_state: Mapping[str, Any] = None, records_slice: Mapping[str, Any] = None) -> Iterable: - """ For the streams that provide the cursor_field `lastModified`, we filter out the old records. """ + """For the streams that provide the cursor_field `lastModified`, we filter out the old records.""" if stream_state: for record in records_slice: if record[self.cursor_field] >= stream_state.get(self.cursor_field): @@ -248,7 +248,7 @@ class LinkedInAdsAnalyticsStream(IncrementalLinkedinAdsStream): @property def base_analytics_params(self) -> MutableMapping[str, Any]: - """ Define the base parameters for analytics streams """ + """Define the base parameters for analytics streams""" return {"q": "analytics", "pivot": self.pivot_by, "timeGranularity": "DAILY"} def request_params(self, stream_state: Mapping[str, Any], stream_slice: Mapping[str, Any] = None, **kwargs) -> MutableMapping[str, Any]: diff --git a/airbyte-integrations/connectors/source-linkedin-ads/unit_tests/analytics_tests/test_merge_chunks.py b/airbyte-integrations/connectors/source-linkedin-ads/unit_tests/analytics_tests/test_merge_chunks.py index d88dd18620a24..4b2a5f5a363e2 100644 --- a/airbyte-integrations/connectors/source-linkedin-ads/unit_tests/analytics_tests/test_merge_chunks.py +++ b/airbyte-integrations/connectors/source-linkedin-ads/unit_tests/analytics_tests/test_merge_chunks.py @@ -9,5 +9,5 @@ def test_merge_chunks(): - """ `merge_chunks` is the generator object, to get the output the list() function is applied """ + """`merge_chunks` is the generator object, to get the output the list() function is applied""" assert list(merge_chunks(test_input_result_record_chunks, TEST_MERGE_BY_KEY)) == test_output_merged_chunks diff --git a/airbyte-integrations/connectors/source-looker/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-looker/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-looker/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-looker/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-marketo/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-marketo/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-marketo/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-marketo/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-mixpanel/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-mixpanel/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-mixpanel/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-mixpanel/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-monday/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-monday/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-monday/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-monday/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-onesignal/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-onesignal/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-onesignal/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-onesignal/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-paypal-transaction/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-paypal-transaction/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-paypal-transaction/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-paypal-transaction/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-paystack/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-paystack/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-paystack/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-paystack/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-pipedrive/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-pipedrive/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-pipedrive/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-pipedrive/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-posthog/integration_tests/dummy_test.py b/airbyte-integrations/connectors/source-posthog/integration_tests/dummy_test.py index 340e7431bc58d..6f3a10993a502 100644 --- a/airbyte-integrations/connectors/source-posthog/integration_tests/dummy_test.py +++ b/airbyte-integrations/connectors/source-posthog/integration_tests/dummy_test.py @@ -4,5 +4,5 @@ def test_dummy(): - """ This is just to fix customIntegration task in Gradle. It fails when pytest unable to find tests.""" + """This is just to fix customIntegration task in Gradle. It fails when pytest unable to find tests.""" assert True diff --git a/airbyte-integrations/connectors/source-quickbooks-singer/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-quickbooks-singer/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-quickbooks-singer/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-quickbooks-singer/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-recharge/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-recharge/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-recharge/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-recharge/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-retently/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-retently/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-retently/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-retently/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-s3/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-s3/integration_tests/acceptance.py index 32dc65e016114..0f93f109de940 100644 --- a/airbyte-integrations/connectors/source-s3/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-s3/integration_tests/acceptance.py @@ -15,7 +15,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-s3/integration_tests/integration_test_abstract.py b/airbyte-integrations/connectors/source-s3/integration_tests/integration_test_abstract.py index 1d4399ab14fbd..737d087be08ef 100644 --- a/airbyte-integrations/connectors/source-s3/integration_tests/integration_test_abstract.py +++ b/airbyte-integrations/connectors/source-s3/integration_tests/integration_test_abstract.py @@ -22,7 +22,7 @@ class AbstractTestIncrementalFileStream(ABC): - """ Prefix this class with Abstract so the tests don't run here but only in the children """ + """Prefix this class with Abstract so the tests don't run here but only in the children""" @pytest.fixture(scope="session") def cloud_bucket_prefix(self) -> str: diff --git a/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/formats/csv_parser.py b/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/formats/csv_parser.py index 08e8a13a09196..cc3f830d7c610 100644 --- a/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/formats/csv_parser.py +++ b/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/formats/csv_parser.py @@ -14,7 +14,7 @@ def multiprocess_queuer(func, queue: mp.Queue, *args, **kwargs): - """ this is our multiprocesser helper function, lives at top-level to be Windows-compatible """ + """this is our multiprocesser helper function, lives at top-level to be Windows-compatible""" queue.put(dill.loads(func)(*args, **kwargs)) diff --git a/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/spec.py b/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/spec.py index cba02ca27ac64..ab4125315597b 100644 --- a/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/spec.py +++ b/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/spec.py @@ -90,7 +90,7 @@ def resolve_refs(schema: dict) -> dict: @classmethod def schema(cls) -> dict: - """ we're overriding the schema classmethod to enable some post-processing """ + """we're overriding the schema classmethod to enable some post-processing""" schema = super().schema() cls.check_provider_added(schema) schema = cls.change_format_to_oneOf(schema) diff --git a/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/stream.py b/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/stream.py index 54d89b978999d..f7152491c656e 100644 --- a/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/stream.py +++ b/airbyte-integrations/connectors/source-s3/source_s3/source_files_abstract/stream.py @@ -377,7 +377,7 @@ def cursor_field(self) -> str: return self.ab_last_mod_col def _get_datetime_from_stream_state(self, stream_state: Mapping[str, Any] = None) -> datetime: - """ if no state, we default to 1970-01-01 in order to pick up all files present. """ + """if no state, we default to 1970-01-01 in order to pick up all files present.""" if stream_state is not None and self.cursor_field in stream_state.keys(): return datetime.strptime(stream_state[self.cursor_field], self.datetime_format_string) else: diff --git a/airbyte-integrations/connectors/source-s3/unit_tests/abstract_test_parser.py b/airbyte-integrations/connectors/source-s3/unit_tests/abstract_test_parser.py index b153b627078b9..59da00d5a7a28 100644 --- a/airbyte-integrations/connectors/source-s3/unit_tests/abstract_test_parser.py +++ b/airbyte-integrations/connectors/source-s3/unit_tests/abstract_test_parser.py @@ -11,7 +11,7 @@ class AbstractTestParser(ABC): - """ Prefix this class with Abstract so the tests don't run here but only in the children """ + """Prefix this class with Abstract so the tests don't run here but only in the children""" logger = AirbyteLogger() diff --git a/airbyte-integrations/connectors/source-salesloft/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-salesloft/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-salesloft/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-salesloft/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py index a1c52d74fe81e..4b6c44dfc6139 100644 --- a/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-sentry/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-sentry/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-sentry/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-sentry/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-shopify/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-shopify/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-shopify/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-shopify/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-shopify/integration_tests/integration_test.py b/airbyte-integrations/connectors/source-shopify/integration_tests/integration_test.py index 2824cd4a16cdb..947827faf3111 100644 --- a/airbyte-integrations/connectors/source-shopify/integration_tests/integration_test.py +++ b/airbyte-integrations/connectors/source-shopify/integration_tests/integration_test.py @@ -4,5 +4,5 @@ def test_dummy_test(): - """ this is the dummy test to pass integration tests step """ + """this is the dummy test to pass integration tests step""" pass diff --git a/airbyte-integrations/connectors/source-shopify/source_shopify/auth.py b/airbyte-integrations/connectors/source-shopify/source_shopify/auth.py index 47f0ff8e5c283..bc3ab9db3d97e 100644 --- a/airbyte-integrations/connectors/source-shopify/source_shopify/auth.py +++ b/airbyte-integrations/connectors/source-shopify/source_shopify/auth.py @@ -9,7 +9,7 @@ class NotImplementedAuth(Exception): - """ Not implemented Auth option error""" + """Not implemented Auth option error""" logger = AirbyteLogger() diff --git a/airbyte-integrations/connectors/source-shopify/source_shopify/source.py b/airbyte-integrations/connectors/source-shopify/source_shopify/source.py index e011b74dc3567..49deaec5ed0d2 100644 --- a/airbyte-integrations/connectors/source-shopify/source_shopify/source.py +++ b/airbyte-integrations/connectors/source-shopify/source_shopify/source.py @@ -173,7 +173,7 @@ def read_records( stream_slice: Optional[Mapping[str, Any]] = None, **kwargs, ) -> Iterable[Mapping[str, Any]]: - """ Reading child streams records for each `id` """ + """Reading child streams records for each `id`""" self.logger.info(f"Reading {self.name} for {self.slice_key}: {stream_slice.get(self.slice_key)}") records = super().read_records(stream_slice=stream_slice, **kwargs) diff --git a/airbyte-integrations/connectors/source-shortio/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-shortio/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-shortio/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-shortio/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-snapchat-marketing/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-snapchat-marketing/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-snapchat-marketing/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-snapchat-marketing/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-snapchat-marketing/source_snapchat_marketing/source.py b/airbyte-integrations/connectors/source-snapchat-marketing/source_snapchat_marketing/source.py index a0befec8e2ab4..027ea4ca59890 100644 --- a/airbyte-integrations/connectors/source-snapchat-marketing/source_snapchat_marketing/source.py +++ b/airbyte-integrations/connectors/source-snapchat-marketing/source_snapchat_marketing/source.py @@ -37,7 +37,7 @@ class SnapchatMarketingException(Exception): - """ Just for formatting the exception as SnapchatMarketing""" + """Just for formatting the exception as SnapchatMarketing""" def get_depend_on_ids(depends_on_stream, depends_on_stream_config: Mapping, slice_key_name: str) -> List: @@ -117,7 +117,7 @@ class SnapchatMarketingStream(HttpStream, ABC): @property def response_root_name(self): - """ Using the class name in lower to set the root node for response parsing """ + """Using the class name in lower to set the root node for response parsing""" return self.name @property @@ -259,14 +259,14 @@ def path(self, stream_slice: Mapping[str, Any] = None, **kwargs) -> str: class Organizations(SnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#organizations """ + """Docs: https://marketingapi.snapchat.com/docs/#organizations""" def path(self, **kwargs) -> str: return "me/organizations" class Adaccounts(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-ad-accounts """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-ad-accounts""" depends_on_stream = Organizations slice_key_name = "organization_id" @@ -276,13 +276,13 @@ def path(self, stream_slice: Mapping[str, Any] = None, **kwargs) -> str: class Creatives(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-creatives """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-creatives""" depends_on_stream = Adaccounts class Media(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-media """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-media""" depends_on_stream = Adaccounts @@ -292,25 +292,25 @@ def response_item_name(self): class Campaigns(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-campaigns """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-campaigns""" depends_on_stream = Adaccounts class Ads(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-ads-under-an-ad-account """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-ads-under-an-ad-account""" depends_on_stream = Adaccounts class Adsquads(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-ad-squads-under-an-ad-account """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-ad-squads-under-an-ad-account""" depends_on_stream = Adaccounts class Segments(IncrementalSnapchatMarketingStream): - """ Docs: https://marketingapi.snapchat.com/docs/#get-all-audience-segments """ + """Docs: https://marketingapi.snapchat.com/docs/#get-all-audience-segments""" depends_on_stream = Adaccounts diff --git a/airbyte-integrations/connectors/source-snapchat-marketing/unit_tests/unit_test.py b/airbyte-integrations/connectors/source-snapchat-marketing/unit_tests/unit_test.py index 26f518e63cb15..1892cbfad8418 100644 --- a/airbyte-integrations/connectors/source-snapchat-marketing/unit_tests/unit_test.py +++ b/airbyte-integrations/connectors/source-snapchat-marketing/unit_tests/unit_test.py @@ -32,7 +32,7 @@ def _config() -> Mapping[str, Any]: def test_get_depend_on_ids_none(): - """ Testing the stream that has non parent dependency (like Organizations has no dependency) """ + """Testing the stream that has non parent dependency (like Organizations has no dependency)""" # sync_mode: SyncMode, cursor_field: List[str] = None, stream_state: Mapping[str, Any] = None depends_on_stream = None slice_key_name = None @@ -41,7 +41,7 @@ def test_get_depend_on_ids_none(): def test_get_depend_on_ids_1(): - """ Testing the stream that has 1 level parent dependency (like Adaccounts has dependency on Organizations) """ + """Testing the stream that has 1 level parent dependency (like Adaccounts has dependency on Organizations)""" # sync_mode: SyncMode, cursor_field: List[str] = None, stream_state: Mapping[str, Any] = None depends_on_stream = Organizations slice_key_name = "organization_id" diff --git a/airbyte-integrations/connectors/source-square/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-square/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-square/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-square/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-square/source_square/source.py b/airbyte-integrations/connectors/source-square/source_square/source.py index 86f1b48dbb199..1c697cfce1d70 100644 --- a/airbyte-integrations/connectors/source-square/source_square/source.py +++ b/airbyte-integrations/connectors/source-square/source_square/source.py @@ -17,7 +17,7 @@ class SquareException(Exception): - """ Just for formatting the exception as Square""" + """Just for formatting the exception as Square""" def __init__(self, status_code, errors): self.status_code = status_code @@ -211,7 +211,7 @@ class ModifierList(IncrementalSquareCatalogObjectsStream): class Refunds(IncrementalSquareStream): - """ Docs: https://developer.squareup.com/reference/square_2021-06-16/refunds-api/list-payment-refunds """ + """Docs: https://developer.squareup.com/reference/square_2021-06-16/refunds-api/list-payment-refunds""" data_field = "refunds" @@ -226,7 +226,7 @@ def request_params(self, **kwargs) -> MutableMapping[str, Any]: class Payments(IncrementalSquareStream): - """ Docs: https://developer.squareup.com/reference/square_2021-06-16/payments-api/list-payments """ + """Docs: https://developer.squareup.com/reference/square_2021-06-16/payments-api/list-payments""" data_field = "payments" @@ -241,7 +241,7 @@ def request_params(self, **kwargs) -> MutableMapping[str, Any]: class Locations(SquareStream): - """ Docs: https://developer.squareup.com/explorer/square/locations-api/list-locations """ + """Docs: https://developer.squareup.com/explorer/square/locations-api/list-locations""" data_field = "locations" @@ -250,7 +250,7 @@ def path(self, **kwargs) -> str: class Shifts(SquareStreamPageJsonAndLimit): - """ Docs: https://developer.squareup.com/reference/square/labor-api/search-shifts """ + """Docs: https://developer.squareup.com/reference/square/labor-api/search-shifts""" data_field = "shifts" http_method = "POST" @@ -261,7 +261,7 @@ def path(self, **kwargs) -> str: class TeamMembers(SquareStreamPageJsonAndLimit): - """ Docs: https://developer.squareup.com/reference/square/team-api/search-team-members """ + """Docs: https://developer.squareup.com/reference/square/team-api/search-team-members""" data_field = "team_members" http_method = "POST" @@ -271,7 +271,7 @@ def path(self, **kwargs) -> str: class TeamMemberWages(SquareStreamPageParam): - """ Docs: https://developer.squareup.com/reference/square_2021-06-16/labor-api/list-team-member-wages """ + """Docs: https://developer.squareup.com/reference/square_2021-06-16/labor-api/list-team-member-wages""" data_field = "team_member_wages" items_per_page_limit = 200 @@ -296,7 +296,7 @@ def backoff_time(self, response: requests.Response) -> Optional[float]: class Customers(SquareStreamPageParam): - """ Docs: https://developer.squareup.com/reference/square_2021-06-16/customers-api/list-customers """ + """Docs: https://developer.squareup.com/reference/square_2021-06-16/customers-api/list-customers""" data_field = "customers" @@ -313,7 +313,7 @@ def request_params(self, **kwargs) -> MutableMapping[str, Any]: class Orders(SquareStreamPageJson): - """ Docs: https://developer.squareup.com/reference/square/orders-api/search-orders """ + """Docs: https://developer.squareup.com/reference/square/orders-api/search-orders""" data_field = "orders" http_method = "POST" diff --git a/airbyte-integrations/connectors/source-strava/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-strava/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-strava/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-strava/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-surveymonkey/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-surveymonkey/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-surveymonkey/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-surveymonkey/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-tempo/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-tempo/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-tempo/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-tempo/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-tiktok-marketing/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-tiktok-marketing/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-tiktok-marketing/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-tiktok-marketing/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/spec.py b/airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/spec.py index 59391363e3eb5..922015b3ce09e 100644 --- a/airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/spec.py +++ b/airbyte-integrations/connectors/source-tiktok-marketing/source_tiktok_marketing/spec.py @@ -72,7 +72,7 @@ def resolve_refs(schema: dict) -> dict: @classmethod def schema(cls) -> dict: - """ we're overriding the schema classmethod to enable some post-processing """ + """we're overriding the schema classmethod to enable some post-processing""" schema = super().schema() schema = cls.change_format_to_oneOf(schema, "environment") return cls.resolve_refs(schema) diff --git a/airbyte-integrations/connectors/source-twilio/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-twilio/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-twilio/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-twilio/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-typeform/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-typeform/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-typeform/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-typeform/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-us-census/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-us-census/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-us-census/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-us-census/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-woocommerce/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-woocommerce/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-woocommerce/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-woocommerce/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-zendesk-sunshine/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-zendesk-sunshine/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-zendesk-sunshine/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-zendesk-sunshine/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-zendesk-support/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-zendesk-support/integration_tests/acceptance.py index 108075487440f..0347f2a0b143d 100644 --- a/airbyte-integrations/connectors/source-zendesk-support/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-zendesk-support/integration_tests/acceptance.py @@ -10,5 +10,5 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" yield diff --git a/airbyte-integrations/connectors/source-zendesk-support/integration_tests/integration_test.py b/airbyte-integrations/connectors/source-zendesk-support/integration_tests/integration_test.py index 7e64a76aa3cdb..4a4b7f85f65e0 100644 --- a/airbyte-integrations/connectors/source-zendesk-support/integration_tests/integration_test.py +++ b/airbyte-integrations/connectors/source-zendesk-support/integration_tests/integration_test.py @@ -43,11 +43,11 @@ def _test_export_stream(self, stream_cls: type): break def test_export_with_unixtime(self): - """ Tickets stream has 'generated_timestamp' as cursor_field and it is unixtime format'' """ + """Tickets stream has 'generated_timestamp' as cursor_field and it is unixtime format''""" self._test_export_stream(Tickets) def test_export_with_str_datetime(self): - """ Other export streams has 'updated_at' as cursor_field and it is datetime string format """ + """Other export streams has 'updated_at' as cursor_field and it is datetime string format""" self._test_export_stream(Users) def _test_insertion(self, stream_cls: type, index: int = None): diff --git a/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py b/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py index 900b682e17e77..5b8ce5ca93940 100644 --- a/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py +++ b/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py @@ -26,7 +26,7 @@ class SourceZendeskException(Exception): class SourceZendeskSupportStream(HttpStream, ABC): - """"Basic Zendesk class""" + """ "Basic Zendesk class""" primary_key = "id" @@ -321,7 +321,7 @@ def request_params(self, next_page_token: Mapping[str, Any] = None, **kwargs) -> class FullRefreshStream(IncrementalUnsortedPageStream, ABC): - """"Stream for endpoints where there are not any created_at or updated_at fields""" + """ "Stream for endpoints where there are not any created_at or updated_at fields""" # reset to default value cursor_field = SourceZendeskSupportStream.cursor_field diff --git a/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/source.py b/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/source.py index 55741b4e128ae..40165cc26dd97 100644 --- a/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/source.py +++ b/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/source.py @@ -1,6 +1,7 @@ # # Copyright (c) 2021 Airbyte, Inc., all rights reserved. # + from datetime import datetime from typing import Any, List, Mapping, Tuple diff --git a/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/streams.py b/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/streams.py index 9475cadba77ad..6cfc27a47d1b4 100644 --- a/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/streams.py +++ b/airbyte-integrations/connectors/source-zendesk-talk/source_zendesk_talk/streams.py @@ -19,18 +19,18 @@ class ZendeskTalkStream(HttpStream, ABC): primary_key = "id" def __init__(self, subdomain: str, **kwargs): - """ Constructor, accepts subdomain to calculate correct url""" + """Constructor, accepts subdomain to calculate correct url""" super().__init__(**kwargs) self._subdomain = subdomain @property @abstractmethod def data_field(self) -> str: - """ Specifies root object name in a stream response""" + """Specifies root object name in a stream response""" @property def url_base(self) -> str: - """ API base url based on configured subdomain""" + """API base url based on configured subdomain""" return f"https://{self._subdomain}.zendesk.com/api/v2/channels/voice" def backoff_time(self, response: requests.Response) -> Optional[float]: @@ -75,7 +75,7 @@ def request_params( return dict(next_page_token or {}) def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapping]: - """ Simply parse json and iterates over root object""" + """Simply parse json and iterates over root object""" response_json = response.json() if self.data_field: response_json = response_json[self.data_field] @@ -110,7 +110,7 @@ def get_updated_state(self, current_stream_state: MutableMapping[str, Any], late return {self.cursor_field: new_cursor_value} def request_params(self, stream_state=None, **kwargs): - """ Add incremental parameters""" + """Add incremental parameters""" params = super().request_params(stream_state=stream_state, **kwargs) if self.filter_param not in params: @@ -220,7 +220,7 @@ class IVRMenus(IVRs): name = "ivr_menus" def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapping]: - """ Simply parse json and iterates over root object""" + """Simply parse json and iterates over root object""" ivrs = super().parse_response(response=response, **kwargs) for ivr in ivrs: for menu in ivr["menus"]: @@ -235,7 +235,7 @@ class IVRRoutes(IVRs): name = "ivr_routes" def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapping]: - """ Simply parse json and iterates over root object""" + """Simply parse json and iterates over root object""" ivrs = super().parse_response(response=response, **kwargs) for ivr in ivrs: for menu in ivr["menus"]: @@ -310,4 +310,3 @@ class CallLegs(ZendeskTalkIncrementalStream): def path(self, **kwargs) -> str: return "/stats/incremental/legs" - diff --git a/airbyte-integrations/connectors/source-zuora/source_zuora/source.py b/airbyte-integrations/connectors/source-zuora/source_zuora/source.py index 381678529230f..b25fc46f514db 100644 --- a/airbyte-integrations/connectors/source-zuora/source_zuora/source.py +++ b/airbyte-integrations/connectors/source-zuora/source_zuora/source.py @@ -58,11 +58,11 @@ def window_in_days(self) -> float: raise QueryWindowError(value) def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, Any]]: - """ Abstractmethod HTTPStream CDK dependency """ + """Abstractmethod HTTPStream CDK dependency""" return None def request_params(self, stream_state: Mapping[str, Any], **kwargs) -> MutableMapping[str, Any]: - """ Abstractmethod HTTPStream CDK dependency """ + """Abstractmethod HTTPStream CDK dependency""" return {} def base_query_params(self) -> MutableMapping[str, Any]: @@ -82,7 +82,7 @@ class ZuoraBase(ZuoraStream): """ def path(self, **kwargs) -> str: - """ Abstractmethod HTTPStream CDK dependency """ + """Abstractmethod HTTPStream CDK dependency""" return "" def request_kwargs(self, stream_slice: Mapping[str, Any] = None, **kwargs) -> Mapping[str, Any]: @@ -483,11 +483,11 @@ def url_base(self): return self.url def path(self, **kwargs) -> str: - """ Abstractmethod HTTPStream CDK dependency """ + """Abstractmethod HTTPStream CDK dependency""" return "" def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, Any]]: - """ Abstractmethod HTTPStream CDK dependency """ + """Abstractmethod HTTPStream CDK dependency""" return None def parse_response(self, response: requests.Response, **kwargs) -> str: diff --git a/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_endpoint.py b/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_endpoint.py index 469a6a84947c9..d0315eadec581 100644 --- a/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_endpoint.py +++ b/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_endpoint.py @@ -22,5 +22,5 @@ def get_url_base(tenant_endpoint: str) -> str: - """ Define the URL Base from user's input with respect to the ZUORA_TENANT_ENDPOINT_MAP """ + """Define the URL Base from user's input with respect to the ZUORA_TENANT_ENDPOINT_MAP""" return ZUORA_TENANT_ENDPOINT_MAP.get(tenant_endpoint) diff --git a/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_errors.py b/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_errors.py index 289e3ee1c1a86..ee87bfb79c51f 100644 --- a/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_errors.py +++ b/airbyte-integrations/connectors/source-zuora/source_zuora/zuora_errors.py @@ -11,7 +11,7 @@ class Error(Exception): - """ Base Error class for other exceptions """ + """Base Error class for other exceptions""" # Define the instance of the Native Airbyte Logger logger = AirbyteLogger() @@ -26,7 +26,7 @@ def __init__(self, value: Any): class ZOQLQueryError(Error): - """ Base class for ZOQL EXPORT query errors """ + """Base class for ZOQL EXPORT query errors""" def __init__(self, response: requests.Response = None): if response: @@ -39,7 +39,7 @@ def __init__(self, response: requests.Response = None): class ZOQLQueryFailed(ZOQLQueryError): - """ Failed to execute query on the server side """ + """Failed to execute query on the server side""" class ZOQLQueryFieldCannotResolveCursor(Error): diff --git a/airbyte-integrations/connectors/source-zuora/unit_tests/unit_test.py b/airbyte-integrations/connectors/source-zuora/unit_tests/unit_test.py index 9b939a7d01604..fd47175daf70a 100644 --- a/airbyte-integrations/connectors/source-zuora/unit_tests/unit_test.py +++ b/airbyte-integrations/connectors/source-zuora/unit_tests/unit_test.py @@ -4,5 +4,5 @@ def test_example(): - """ Example of unit test """ + """Example of unit test""" pass diff --git a/docs/reference/api/generated-api-html/index.html b/docs/reference/api/generated-api-html/index.html index 3a93ccfe5b888..2748368b6543c 100644 --- a/docs/reference/api/generated-api-html/index.html +++ b/docs/reference/api/generated-api-html/index.html @@ -2534,7 +2534,7 @@

Example data

"predicateValue" : "predicateValue", "oauthConfigSpecification" : { }, "predicateKey" : [ "predicateKey", "predicateKey" ], - "authFlowType" : "oauth1.0" + "authFlowType" : "oauth2.0" }, "authSpecification" : { "auth_type" : "oauth2.0", @@ -4966,7 +4966,7 @@

Example data

"predicateValue" : "predicateValue", "oauthConfigSpecification" : { }, "predicateKey" : [ "predicateKey", "predicateKey" ], - "authFlowType" : "oauth1.0" + "authFlowType" : "oauth2.0" }, "authSpecification" : { "auth_type" : "oauth2.0", @@ -6716,7 +6716,7 @@

AdvancedAuth -
authFlowType (optional)
String
Enum:
-
oauth1.0
oauth2.0
+
oauth2.0
oauth1.0
predicateKey (optional)
array[String] Json Path to a field in the connectorSpecification that should exist for the advanced auth to be applicable.
predicateValue (optional)
String Value of the predicate_key fields for the advanced auth to be applicable.
oauthConfigSpecification (optional)
OAuthConfigSpecification
From ca45417b701a291650342bb1a5ba77261788f64a Mon Sep 17 00:00:00 2001 From: Marcos Marx Date: Mon, 15 Nov 2021 13:46:21 -0300 Subject: [PATCH 4/6] format files --- .../integration_tests/acceptance.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py index 4b6c44dfc6139..a1c52d74fe81e 100644 --- a/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """This fixture is a placeholder for external resources that acceptance test might require.""" + """ This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies From 4d6d3381e5179405f0849cf0bcaa56bc7123e98d Mon Sep 17 00:00:00 2001 From: Marcos Marx Date: Mon, 15 Nov 2021 14:18:43 -0300 Subject: [PATCH 5/6] correct other file --- .../source-scaffold-source-http/integration_tests/acceptance.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py index 056971f954502..58c194c5d1376 100644 --- a/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """This fixture is a placeholder for external resources that acceptance test might require.""" + """ This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies From 39bd25ad63396a18089c1ce0e6634cfa2952047d Mon Sep 17 00:00:00 2001 From: Marcos Marx Date: Mon, 15 Nov 2021 20:00:38 -0300 Subject: [PATCH 6/6] correct files --- .../source-scaffold-source-http/integration_tests/acceptance.py | 2 +- .../integration_tests/acceptance.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py index 58c194c5d1376..056971f954502 100644 --- a/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-scaffold-source-http/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies if needed. otherwise remove the TODO comments yield # TODO: clean up test dependencies diff --git a/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py index a1c52d74fe81e..4b6c44dfc6139 100644 --- a/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py +++ b/airbyte-integrations/connectors/source-scaffold-source-python/integration_tests/acceptance.py @@ -10,7 +10,7 @@ @pytest.fixture(scope="session", autouse=True) def connector_setup(): - """ This fixture is a placeholder for external resources that acceptance test might require.""" + """This fixture is a placeholder for external resources that acceptance test might require.""" # TODO: setup test dependencies yield # TODO: clean up test dependencies