run format (#15566)

airbytehq · Aug 11, 2022 · 6d11687 · 6d11687
1 parent 3b527a1
commit 6d11687
Show file tree

Hide file tree

Showing 17 changed files with 676 additions and 1,143 deletions.
diff --git a/...java/io/airbyte/integrations/destination/azure_blob_storage/AzureBlobStorageConsumer.java b/...java/io/airbyte/integrations/destination/azure_blob_storage/AzureBlobStorageConsumer.java
@@ -45,10 +45,10 @@ public class AzureBlobStorageConsumer extends FailureTrackingAirbyteMessageConsu
   private final Map<AirbyteStreamNameNamespacePair, AzureBlobStorageWriter> streamNameAndNamespaceToWriters;
 
   public AzureBlobStorageConsumer(
-      final AzureBlobStorageDestinationConfig azureBlobStorageDestinationConfig,
-      final ConfiguredAirbyteCatalog configuredCatalog,
-      final AzureBlobStorageWriterFactory writerFactory,
-      final Consumer<AirbyteMessage> outputRecordCollector) {
+                                  final AzureBlobStorageDestinationConfig azureBlobStorageDestinationConfig,
+                                  final ConfiguredAirbyteCatalog configuredCatalog,
+                                  final AzureBlobStorageWriterFactory writerFactory,
+                                  final Consumer<AirbyteMessage> outputRecordCollector) {
     this.azureBlobStorageDestinationConfig = azureBlobStorageDestinationConfig;
     this.configuredCatalog = configuredCatalog;
     this.writerFactory = writerFactory;
@@ -91,8 +91,8 @@ protected void startTracked() throws Exception {
   }
 
   private void createContainers(final SpecializedBlobClientBuilder specializedBlobClientBuilder,
-      final AppendBlobClient appendBlobClient,
-      final ConfiguredAirbyteStream configuredStream) {
+                                final AppendBlobClient appendBlobClient,
+                                final ConfiguredAirbyteStream configuredStream) {
     // create container if absent (aka SQl Schema)
     final BlobContainerClient containerClient = appendBlobClient.getContainerClient();
     if (!containerClient.exists()) {
@@ -101,7 +101,7 @@ private void createContainers(final SpecializedBlobClientBuilder specializedBlob
     if (DestinationSyncMode.OVERWRITE.equals(configuredStream.getDestinationSyncMode())) {
       LOGGER.info("Sync mode is selected to OVERRIDE mode. New container will be automatically"
           + " created or all data would be overridden (if any) for stream:" + configuredStream
-          .getStream().getName());
+              .getStream().getName());
       var blobItemList = StreamSupport.stream(containerClient.listBlobs().spliterator(), false)
           .collect(Collectors.toList());
       blobItemList.forEach(blob -> {

diff --git a/...a/io/airbyte/integrations/destination/azure_blob_storage/AzureBlobRecordConsumerTest.java b/...a/io/airbyte/integrations/destination/azure_blob_storage/AzureBlobRecordConsumerTest.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.destination.azure_blob_storage;
 
 import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
@@ -9,20 +13,20 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.extension.ExtendWith;
-import org.mockito.InjectMocks;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
 
 @DisplayName("AzureBlobRecordConsumer")
 @ExtendWith(MockitoExtension.class)
 public class AzureBlobRecordConsumerTest extends PerStreamStateMessageTest {
+
   @Mock
   private Consumer<AirbyteMessage> outputRecordCollector;
 
   private AzureBlobStorageConsumer consumer;
 
   @Mock
-  private  AzureBlobStorageDestinationConfig azureBlobStorageDestinationConfig;
+  private AzureBlobStorageDestinationConfig azureBlobStorageDestinationConfig;
 
   @Mock
   private ConfiguredAirbyteCatalog configuredCatalog;
@@ -44,4 +48,5 @@ protected Consumer<AirbyteMessage> getMockedConsumer() {
   protected FailureTrackingAirbyteMessageConsumer getMessageConsumer() {
     return consumer;
   }
+
 }
diff --git a/...la/src/test/java/io/airbyte/integrations/destination/scylla/ScyllaRecordConsumerTest.java b/...la/src/test/java/io/airbyte/integrations/destination/scylla/ScyllaRecordConsumerTest.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.destination.scylla;
 
 import com.fasterxml.jackson.databind.JsonNode;
@@ -17,6 +21,7 @@
 @DisplayName("ScyllaRecordConsumer")
 @ExtendWith(MockitoExtension.class)
 public class ScyllaRecordConsumerTest extends PerStreamStateMessageTest {
+
   private static ScyllaContainer scyllaContainer;
 
   @Mock
@@ -68,4 +73,5 @@ public ScyllaContainer() {
     }
 
   }
+
 }
diff --git a/airbyte-integrations/connectors/source-hubplanner/sample_files/configured_catalog.json b/airbyte-integrations/connectors/source-hubplanner/sample_files/configured_catalog.json
@@ -8,9 +8,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },
@@ -27,9 +27,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },
@@ -46,9 +46,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },
@@ -65,9 +65,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },
@@ -84,9 +84,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },
@@ -103,9 +103,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },
@@ -122,9 +122,9 @@
           "type": "object",
           "properties": {
             "api_key": {
-                "type": "string",
-                "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
-                "airbyte_secret": true
+              "type": "string",
+              "description": "Hubplanner API key. See  <a href=\"https://github.com/hubplanner/API#authentication\" target=\"_blank\">here</a> for more details.",
+              "airbyte_secret": true
             }
           }
         },

diff --git a/...te-integrations/connectors/source-hubplanner/source_hubplanner/schemas/billing_rates.json b/...te-integrations/connectors/source-hubplanner/source_hubplanner/schemas/billing_rates.json
@@ -1,45 +1,30 @@
 {
-    "$schema": "http://json-schema.org/draft-07/schema#",
-    "type": "object",
-    "additionalProperties": true,
-    "properties": {
-        "_id": {
-            "type": [
-                "null",
-                "string"
-            ]
-        },
-        "rate": {
-            "type": [
-                "null",
-                "number"
-            ]
-        },
-        "metadata": {
-            "type": [
-                "null",
-                "string"
-            ]
-        },
-        "createdDate": {
-            "type": [
-                "null",
-                "string"
-            ],
-            "format": "date-time"
-        },
-        "updatedDate": {
-            "type": [
-                "null",
-                "string"
-            ],
-            "format": "date-time"
-        },
-        "label": {
-            "type": "string"
-        },
-        "currency": {
-            "type": "string"
-        }
+  "$schema": "http://json-schema.org/draft-07/schema#",
+  "type": "object",
+  "additionalProperties": true,
+  "properties": {
+    "_id": {
+      "type": ["null", "string"]
+    },
+    "rate": {
+      "type": ["null", "number"]
+    },
+    "metadata": {
+      "type": ["null", "string"]
+    },
+    "createdDate": {
+      "type": ["null", "string"],
+      "format": "date-time"
+    },
+    "updatedDate": {
+      "type": ["null", "string"],
+      "format": "date-time"
+    },
+    "label": {
+      "type": "string"
+    },
+    "currency": {
+      "type": "string"
     }
-}
+  }
+}