fix formatting + imports (airbytehq#18457)

jhammarstedt · Oct 31, 2022 · 9ef2233 · 9ef2233
1 parent 5161d4a
commit 9ef2233
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 8 deletions.
diff --git a/...s/base-java-s3/src/test/java/io/airbyte/integrations/destination/s3/S3BaseChecksTest.java b/...s/base-java-s3/src/test/java/io/airbyte/integrations/destination/s3/S3BaseChecksTest.java
@@ -1,8 +1,11 @@
+/*
+ * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.destination.s3;
 
 import static org.mockito.ArgumentMatchers.anyString;
 import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.ArgumentMatchers.matches;
 import static org.mockito.ArgumentMatchers.startsWith;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
@@ -34,8 +37,7 @@ public void attemptWriteAndDeleteS3Object_should_createSpecificFiles() {
         null,
         null,
         null,
-        s3Client
-    );
+        s3Client);
     S3StorageOperations operations = new S3StorageOperations(new S3NameTransformer(), s3Client, config);
     when(s3Client.doesObjectExist("test_bucket", "test/bucket/path/")).thenReturn(false);
 
@@ -46,4 +48,5 @@ public void attemptWriteAndDeleteS3Object_should_createSpecificFiles() {
     verify(s3Client).listObjects(ArgumentMatchers.<ListObjectsRequest>argThat(request -> "test_bucket".equals(request.getBucketName())));
     verify(s3Client).deleteObject(eq("test_bucket"), startsWith("test/bucket/path/_airbyte_connection_test_"));
   }
+
 }
diff --git a/...ntegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/ssh/SshTunnel.java b/...ntegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/ssh/SshTunnel.java
@@ -6,7 +6,6 @@
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.google.common.base.Preconditions;
-import io.airbyte.commons.exceptions.ConnectionErrorException;
 import io.airbyte.commons.functional.CheckedConsumer;
 import io.airbyte.commons.functional.CheckedFunction;
 import io.airbyte.commons.json.Jsons;

diff --git a/...bases/base-java/src/main/java/io/airbyte/integrations/base/ssh/SshWrappedDestination.java b/...bases/base-java/src/main/java/io/airbyte/integrations/base/ssh/SshWrappedDestination.java
@@ -6,7 +6,6 @@
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.node.ObjectNode;
-import io.airbyte.commons.exceptions.ConnectionErrorException;
 import io.airbyte.commons.json.Jsons;
 import io.airbyte.commons.resources.MoreResources;
 import io.airbyte.integrations.base.AirbyteMessageConsumer;
@@ -19,7 +18,6 @@
 import io.airbyte.protocol.models.ConnectorSpecification;
 import java.util.List;
 import java.util.function.Consumer;
-import org.apache.sshd.common.SshException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/...ions/bases/base-java/src/main/java/io/airbyte/integrations/base/ssh/SshWrappedSource.java b/...ions/bases/base-java/src/main/java/io/airbyte/integrations/base/ssh/SshWrappedSource.java
@@ -5,7 +5,6 @@
 package io.airbyte.integrations.base.ssh;
 
 import com.fasterxml.jackson.databind.JsonNode;
-import io.airbyte.commons.exceptions.ConnectionErrorException;
 import io.airbyte.commons.util.AutoCloseableIterator;
 import io.airbyte.commons.util.AutoCloseableIterators;
 import io.airbyte.integrations.base.AirbyteTraceMessageUtility;
@@ -17,7 +16,6 @@
 import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
 import io.airbyte.protocol.models.ConnectorSpecification;
 import java.util.List;
-import org.apache.sshd.common.SshException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;