🎉 New Source: DataScope

8cee7c4a-8047-4cb9-a86d-f7fd87b2d1f8.json

@@ -0,0 +1,7 @@
+{
+  "sourceDefinitionId": "8cee7c4a-8047-4cb9-a86d-f7fd87b2d1f8",
+  "name": "DataScope",
+  "dockerRepository": "airbyte/datascope",
+  "dockerImageTag": "0.1.0",
+  "documentationUrl": "https://docs.airbyte.io/integrations/sources/datascope"
+}

airbyte-integrations/connectors/destination-kvdb/destination_kvdb/writer.py

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 from collections import Mapping
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 import hashlib
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,16 +1,7 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
-import pytest
-
-pytest_plugins = ("source_acceptance_test.plugin",)
-
-
-@pytest.fixture(scope="session", autouse=True)
-def connector_setup():
-    """ 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
+def test_dummy_test():
+    assert True

airbyte-integrations/connectors/source-apify-dataset/integration_tests/acceptance.py

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -10,7 +10,5 @@
 
 @pytest.fixture(scope="session", autouse=True)
 def connector_setup():
-    """ This fixture is a placeholder for external resources that acceptance test might require."""
-    # TODO: setup test dependencies if needed. otherwise remove the TODO comments
+    """This fixture is a placeholder for external resources that acceptance test might require."""
     yield
-    # TODO: clean up test dependencies

airbyte-integrations/connectors/source-aws-cloudtrail/integration_tests/acceptance.py

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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-bamboo-hr/integration_tests/acceptance.py

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+# Copyright (c) 2022 Airbyte, Inc., all rights reserved.
 #
 
 
@@ -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) 2022 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.source.cockroachdb;
 
 import com.fasterxml.jackson.databind.JsonNode;
@@ -14,7 +18,7 @@
 public class CockroachJdbcSourceOperations extends JdbcSourceOperations {
 
   @Override
-  protected void putBoolean(ObjectNode node, String columnName, ResultSet resultSet, int index) throws SQLException {
+  protected void putBoolean(final ObjectNode node, final String columnName, final ResultSet resultSet, final int index) throws SQLException {
     if ("bit".equalsIgnoreCase(resultSet.getMetaData().getColumnTypeName(index))) {
       node.put(columnName, resultSet.getByte(index));
     } else {
@@ -28,12 +32,12 @@ protected void putDouble(final ObjectNode node, final String columnName, final R
   }
 
   @Override
-  protected void putNumber(final ObjectNode node, final String columnName, final ResultSet resultSet, final int index) throws SQLException {
+  protected void putBigDecimal(final ObjectNode node, final String columnName, final ResultSet resultSet, final int index) throws SQLException {
     node.put(columnName, resultSet.getBigDecimal(index));
   }
 
   @Override
-  public JsonNode rowToJson(ResultSet queryContext) throws SQLException {
+  public JsonNode rowToJson(final ResultSet queryContext) throws SQLException {
     final int columnCount = queryContext.getMetaData().getColumnCount();
     final ObjectNode jsonNode = (ObjectNode) Jsons.jsonNode(Collections.emptyMap());
 
@@ -43,16 +47,16 @@ public JsonNode rowToJson(ResultSet queryContext) throws SQLException {
         if (!queryContext.wasNull()) {
           setJsonField(queryContext, i, jsonNode);
         }
-      } catch (SQLException e) {
+      } catch (final SQLException e) {
         putCockroachSpecialDataType(queryContext, i, jsonNode);
       }
     }
     return jsonNode;
   }
 
-  private void putCockroachSpecialDataType(ResultSet resultSet, int index, ObjectNode node) throws SQLException {
-    String columnType = resultSet.getMetaData().getColumnTypeName(index);
-    String columnName = resultSet.getMetaData().getColumnName(index);
+  private void putCockroachSpecialDataType(final ResultSet resultSet, final int index, final ObjectNode node) throws SQLException {
+    final String columnType = resultSet.getMetaData().getColumnTypeName(index);
+    final String columnName = resultSet.getMetaData().getColumnName(index);
     try {
       if ("numeric".equalsIgnoreCase(columnType)) {
         final double value = resultSet.getDouble(index);
@@ -64,4 +68,5 @@ private void putCockroachSpecialDataType(ResultSet resultSet, int index, ObjectN
       node.put(columnName, (Double) null);
     }
   }
+
 }