From 769a7b6d403bb343baacb100d334dfd4d4ab9074 Mon Sep 17 00:00:00 2001 From: Octavia Squidington III Date: Thu, 9 Jan 2025 21:26:31 +0000 Subject: [PATCH] chore: auto-fix lint and format issues --- .../destination/s3_data_lake/io/S3DataLakeUtil.kt | 4 +++- .../destination/s3_data_lake/S3DataLakeTestUtil.kt | 3 ++- .../destination/s3_data_lake/io/S3DataLakeUtilTest.kt | 3 ++- 3 files changed, 7 insertions(+), 3 deletions(-) diff --git a/airbyte-integrations/connectors/destination-s3-data-lake/src/main/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtil.kt b/airbyte-integrations/connectors/destination-s3-data-lake/src/main/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtil.kt index 6e1ef5abf1e7..4e694978c11d 100644 --- a/airbyte-integrations/connectors/destination-s3-data-lake/src/main/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtil.kt +++ b/airbyte-integrations/connectors/destination-s3-data-lake/src/main/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtil.kt @@ -339,7 +339,9 @@ class S3DataLakeUtil( ) } - private fun buildKeyBasedClientProperties(config: S3DataLakeConfiguration): Map { + private fun buildKeyBasedClientProperties( + config: S3DataLakeConfiguration + ): Map { val awsAccessKeyId = requireNotNull(config.awsAccessKeyConfiguration.accessKeyId) { "AWS Access Key ID is required for key-based authentication" diff --git a/airbyte-integrations/connectors/destination-s3-data-lake/src/test-integration/kotlin/io/airbyte/integrations/destination/s3_data_lake/S3DataLakeTestUtil.kt b/airbyte-integrations/connectors/destination-s3-data-lake/src/test-integration/kotlin/io/airbyte/integrations/destination/s3_data_lake/S3DataLakeTestUtil.kt index 7f471251ad36..d03fc4be4420 100644 --- a/airbyte-integrations/connectors/destination-s3-data-lake/src/test-integration/kotlin/io/airbyte/integrations/destination/s3_data_lake/S3DataLakeTestUtil.kt +++ b/airbyte-integrations/connectors/destination-s3-data-lake/src/test-integration/kotlin/io/airbyte/integrations/destination/s3_data_lake/S3DataLakeTestUtil.kt @@ -35,7 +35,8 @@ object S3DataLakeTestUtil { } fun getConfig(spec: ConfigurationSpecification) = - S3DataLakeConfigurationFactory().makeWithoutExceptionHandling(spec as S3DataLakeSpecification) + S3DataLakeConfigurationFactory() + .makeWithoutExceptionHandling(spec as S3DataLakeSpecification) fun getCatalog(config: S3DataLakeConfiguration, awsSystemCredentials: AWSSystemCredentials) = S3DataLakeUtil(SimpleTableIdGenerator(), awsSystemCredentials).let { icebergUtil -> diff --git a/airbyte-integrations/connectors/destination-s3-data-lake/src/test/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtilTest.kt b/airbyte-integrations/connectors/destination-s3-data-lake/src/test/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtilTest.kt index e2320bcb8a6e..ce12721a7419 100644 --- a/airbyte-integrations/connectors/destination-s3-data-lake/src/test/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtilTest.kt +++ b/airbyte-integrations/connectors/destination-s3-data-lake/src/test/kotlin/io/airbyte/integrations/destination/s3_data_lake/io/S3DataLakeUtilTest.kt @@ -70,7 +70,8 @@ internal class S3DataLakeUtilTest { URI to "http://localhost:19120/api/v1", WAREHOUSE_LOCATION to "s3://test/" ) - val catalog = s3DataLakeUtil.createCatalog(catalogName = catalogName, properties = properties) + val catalog = + s3DataLakeUtil.createCatalog(catalogName = catalogName, properties = properties) assertNotNull(catalog) assertEquals(catalogName, catalog.name()) assertEquals(NessieCatalog::class.java, catalog.javaClass)