Format code

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)

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

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

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:

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

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

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

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

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

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

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

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

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

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

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

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

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

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);
     }
   }
+
 }

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")

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

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

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

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;

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;

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

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

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):

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

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

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

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

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

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

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

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

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

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

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

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

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)

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

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

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

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

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

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