format zendesk sunshine connector (#4658)

airbytehq · Jul 22, 2021 · f1304fa · f1304fa
1 parent 86f05e4
commit f1304fa
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 33 deletions.
diff --git a/...integrations/connectors/source-zendesk-sunshine/integration_tests/configured_catalog.json b/...integrations/connectors/source-zendesk-sunshine/integration_tests/configured_catalog.json
@@ -34,10 +34,7 @@
             }
           }
         },
-        "supported_sync_modes": [
-          "full_refresh",
-          "incremental"
-        ],
+        "supported_sync_modes": ["full_refresh", "incremental"],
         "source_defined_cursor": true,
         "default_cursor_field": []
       },
@@ -71,10 +68,7 @@
             }
           }
         },
-        "supported_sync_modes": [
-          "full_refresh",
-          "incremental"
-        ],
+        "supported_sync_modes": ["full_refresh", "incremental"],
         "source_defined_cursor": true,
         "default_cursor_field": ["updated_at"]
       },
@@ -105,10 +99,7 @@
             }
           }
         },
-        "supported_sync_modes": [
-          "full_refresh",
-          "incremental"
-        ],
+        "supported_sync_modes": ["full_refresh", "incremental"],
         "source_defined_cursor": true,
         "default_cursor_field": []
       },
@@ -139,10 +130,7 @@
             }
           }
         },
-        "supported_sync_modes": [
-          "full_refresh",
-          "incremental"
-        ],
+        "supported_sync_modes": ["full_refresh", "incremental"],
         "source_defined_cursor": true,
         "default_cursor_field": []
       },
@@ -217,10 +205,7 @@
             }
           }
         },
-        "supported_sync_modes": [
-          "full_refresh",
-          "incremental"
-        ],
+        "supported_sync_modes": ["full_refresh", "incremental"],
         "source_defined_cursor": true,
         "default_cursor_field": []
       },
@@ -245,10 +230,7 @@
             }
           }
         },
-        "supported_sync_modes": [
-          "full_refresh",
-          "incremental"
-        ],
+        "supported_sync_modes": ["full_refresh", "incremental"],
         "source_defined_cursor": true,
         "default_cursor_field": []
       },

diff --git a/airbyte-integrations/connectors/source-zendesk-sunshine/source_zendesk_sunshine/source.py b/airbyte-integrations/connectors/source-zendesk-sunshine/source_zendesk_sunshine/source.py
@@ -33,14 +33,7 @@
 from airbyte_cdk.sources.streams import Stream
 from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
 
-from .streams import (
-    Limits,
-    ObjectRecords,
-    ObjectTypePolicies,
-    ObjectTypes,
-    RelationshipRecords,
-    RelationshipTypes,
-)
+from .streams import Limits, ObjectRecords, ObjectTypePolicies, ObjectTypes, RelationshipRecords, RelationshipTypes
 
 
 class Base64HttpAuthenticator(TokenAuthenticator):

diff --git a/airbyte-integrations/connectors/source-zendesk-sunshine/source_zendesk_sunshine/spec.json b/airbyte-integrations/connectors/source-zendesk-sunshine/source_zendesk_sunshine/spec.json
@@ -4,7 +4,7 @@
     "$schema": "http://json-schema.org/draft-07/schema#",
     "title": "Zendesk Sunshine Spec",
     "type": "object",
-    "required": ["api_token", "email", "start_date" ,"subdomain"],
+    "required": ["api_token", "email", "start_date", "subdomain"],
     "additionalProperties": false,
     "properties": {
       "api_token": {

diff --git a/airbyte-integrations/connectors/source-zendesk-sunshine/source_zendesk_sunshine/streams.py b/airbyte-integrations/connectors/source-zendesk-sunshine/source_zendesk_sunshine/streams.py
@@ -108,6 +108,7 @@ class ObjectRecords(IncrementalSunshineStream):
     To support Incremental for this stream I had to use `query` endpoint instead of `objects/records` -
     this allows me to use date filters. This is the only way to have incremental support.
     """
+
     http_method = "POST"
 
     def request_body_json(
@@ -213,6 +214,7 @@ class Jobs(SunshineStream):
     This stream is dynamic. The data can exist today, but may be absent tomorrow.
     Since we need to have some data in the stream this stream is disabled.
     """
+
     def path(self, **kwargs) -> str:
         return "jobs"