publish PR 4550 (#5219)

Co-authored-by: Rodrigo Parra <[email protected]>
airbytehq · Aug 5, 2021 · 6b07d30 · 6b07d30
1 parent de0d6fc
commit 6b07d30
Show file tree

Hide file tree

Showing 13 changed files with 223 additions and 185 deletions.
diff --git a/.../airbyte/integrations/destination/snowflake/SnowflakeInsertDestinationAcceptanceTest.java b/.../airbyte/integrations/destination/snowflake/SnowflakeInsertDestinationAcceptanceTest.java
@@ -34,7 +34,6 @@
 import io.airbyte.integrations.base.JavaBaseConstants;
 import io.airbyte.integrations.destination.ExtendedNameTransformer;
 import io.airbyte.integrations.standardtest.destination.DestinationAcceptanceTest;
-
 import java.nio.file.Path;
 import java.sql.SQLException;
 import java.util.ArrayList;

diff --git a/airbyte-integrations/connectors/source-apify-dataset/integration_tests/catalog.json b/airbyte-integrations/connectors/source-apify-dataset/integration_tests/catalog.json
@@ -1,13 +1,13 @@
 {
-    "streams": [
-        {
-            "name": "DatasetItems",
-            "supported_sync_modes": ["full_refresh"],
-            "destination_sync_mode": "overwrite",
-            "json_schema": {
-                "$schema": "http://json-schema.org/draft-07/schema#",
-                "type": "object"
-            }
-        }
-    ]
-  }
+  "streams": [
+    {
+      "name": "DatasetItems",
+      "supported_sync_modes": ["full_refresh"],
+      "destination_sync_mode": "overwrite",
+      "json_schema": {
+        "$schema": "http://json-schema.org/draft-07/schema#",
+        "type": "object"
+      }
+    }
+  ]
+}
diff --git a/airbyte-integrations/connectors/source-apify-dataset/integration_tests/invalid_config.json b/airbyte-integrations/connectors/source-apify-dataset/integration_tests/invalid_config.json
@@ -1,4 +1,4 @@
 {
-    "datasetId": "non_existent_dataset_id",
-    "clean": false
+  "datasetId": "non_existent_dataset_id",
+  "clean": false
 }
diff --git a/airbyte-integrations/connectors/source-apify-dataset/source_apify_dataset/spec.json b/airbyte-integrations/connectors/source-apify-dataset/source_apify_dataset/spec.json
@@ -7,14 +7,14 @@
     "required": ["datasetId"],
     "additionalProperties": false,
     "properties": {
-        "datasetId": {
-            "type": "string",
-            "description": "ID of the dataset you would like to load to Airbyte."
-        },
-        "clean": {
-            "type": "boolean",
-            "description": "If set to true, only clean items will be downloaded from the dataset. See description of what clean means in <a href=\"https://docs.apify.com/api/v2#/reference/datasets/item-collection/get-items\">Apify API docs</a>. If not sure, set clean to false."
-        }
+      "datasetId": {
+        "type": "string",
+        "description": "ID of the dataset you would like to load to Airbyte."
+      },
+      "clean": {
+        "type": "boolean",
+        "description": "If set to true, only clean items will be downloaded from the dataset. See description of what clean means in <a href=\"https://docs.apify.com/api/v2#/reference/datasets/item-collection/get-items\">Apify API docs</a>. If not sure, set clean to false."
+      }
     }
   }
 }
diff --git a/airbyte-integrations/connectors/source-hubspot/source_hubspot/api.py b/airbyte-integrations/connectors/source-hubspot/source_hubspot/api.py
@@ -27,7 +27,7 @@
 import time
 from abc import ABC, abstractmethod
 from datetime import datetime, timedelta
-from functools import partial, lru_cache
+from functools import lru_cache, partial
 from http import HTTPStatus
 from typing import Any, Callable, Iterable, Iterator, List, Mapping, MutableMapping, Optional, Union
 
@@ -288,16 +288,7 @@ def _cast_value(declared_field_types: List, field_name: str, field_value):
 
     def _cast_record_fields_if_needed(self, record: Mapping, properties: Mapping[str, Any] = None) -> Mapping:
 
-        if self.entity not in {
-            "contact",
-            "engagement",
-            "product",
-            "quote",
-            "ticket",
-            "company",
-            "deal",
-            "line_item"
-        }:
+        if self.entity not in {"contact", "engagement", "product", "quote", "ticket", "company", "deal", "line_item"}:
             return record
 
         if not record.get("properties"):

diff --git a/airbyte-integrations/connectors/source-hubspot/unit_tests/test_field_type_converting.py b/airbyte-integrations/connectors/source-hubspot/unit_tests/test_field_type_converting.py
@@ -1,7 +1,7 @@
 #
 # MIT License
 #
-# Copyright (c) 2021 Airbyte
+# Copyright (c) 2020 Airbyte
 #
 # Permission is hereby granted, free of charge, to any person obtaining a copy
 # of this software and associated documentation files (the "Software"), to deal

diff --git a/airbyte-integrations/connectors/source-kustomer-singer/integration_tests/acceptance.py b/airbyte-integrations/connectors/source-kustomer-singer/integration_tests/acceptance.py
@@ -1,3 +1,4 @@
+#
 # MIT License
 #
 # Copyright (c) 2020 Airbyte
@@ -19,6 +20,7 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
+#
 
 
 import pytest

diff --git a/airbyte-integrations/connectors/source-kustomer-singer/main.py b/airbyte-integrations/connectors/source-kustomer-singer/main.py
@@ -1,3 +1,4 @@
+#
 # MIT License
 #
 # Copyright (c) 2020 Airbyte
@@ -19,6 +20,7 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
+#
 
 import sys
 

diff --git a/airbyte-integrations/connectors/source-kustomer-singer/setup.py b/airbyte-integrations/connectors/source-kustomer-singer/setup.py
@@ -1,3 +1,4 @@
+#
 # MIT License
 #
 # Copyright (c) 2020 Airbyte
@@ -19,6 +20,7 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
+#
 
 from setuptools import find_packages, setup
 

diff --git a/airbyte-integrations/connectors/source-kustomer-singer/source_kustomer_singer/source.py b/airbyte-integrations/connectors/source-kustomer-singer/source_kustomer_singer/source.py
@@ -1,3 +1,4 @@
+#
 # MIT License
 #
 # Copyright (c) 2020 Airbyte
@@ -19,6 +20,7 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
+#
 
 
 import json

diff --git a/airbyte-integrations/connectors/source-kustomer-singer/unit_tests/unit_test.py b/airbyte-integrations/connectors/source-kustomer-singer/unit_tests/unit_test.py
@@ -1,3 +1,4 @@
+#
 # MIT License
 #
 # Copyright (c) 2020 Airbyte
@@ -19,6 +20,7 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
+#
 
 
 def test_example_method():