diff --git a/airbyte-integrations/connectors/destination-snowflake/src/test/java/io/airbyte/integrations/destination/snowflake/SnowflakeDestinationTest.java b/airbyte-integrations/connectors/destination-snowflake/src/test/java/io/airbyte/integrations/destination/snowflake/SnowflakeDestinationTest.java index 021fa9ed88feb..bfa451bbd0c9b 100644 --- a/airbyte-integrations/connectors/destination-snowflake/src/test/java/io/airbyte/integrations/destination/snowflake/SnowflakeDestinationTest.java +++ b/airbyte-integrations/connectors/destination-snowflake/src/test/java/io/airbyte/integrations/destination/snowflake/SnowflakeDestinationTest.java @@ -14,16 +14,11 @@ import io.airbyte.commons.io.IOs; import io.airbyte.commons.jackson.MoreMappers; import io.airbyte.commons.json.Jsons; +import io.airbyte.commons.resources.MoreResources; import io.airbyte.db.jdbc.JdbcDatabase; import io.airbyte.integrations.base.AirbyteMessageConsumer; import io.airbyte.integrations.base.Destination; -import io.airbyte.protocol.models.AirbyteMessage; -import io.airbyte.protocol.models.AirbyteRecordMessage; -import io.airbyte.protocol.models.CatalogHelpers; -import io.airbyte.protocol.models.ConfiguredAirbyteCatalog; -import io.airbyte.protocol.models.DestinationSyncMode; -import io.airbyte.protocol.models.Field; -import io.airbyte.protocol.models.JsonSchemaPrimitive; +import io.airbyte.protocol.models.*; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; @@ -81,8 +76,7 @@ public void testCleanupStageOnFailure() throws Exception { JdbcDatabase mockDb = mock(JdbcDatabase.class); SnowflakeStagingSqlOperations sqlOperations = mock(SnowflakeStagingSqlOperations.class); final var testMessages = generateTestMessages(); - final JsonNode config = Jsons.deserialize(IOs.readFile(Path.of("secrets/insert_config.json"))); - + final JsonNode config = Jsons.deserialize(MoreResources.readResource("insert_config.json"), JsonNode.class); AirbyteMessageConsumer airbyteMessageConsumer = new SnowflakeInternalStagingConsumerFactory() .create(Destination::defaultOutputRecordCollector, mockDb, sqlOperations, new SnowflakeSQLNameTransformer(), config, getCatalog()); diff --git a/airbyte-integrations/connectors/destination-snowflake/src/test/resources/insert_config.json b/airbyte-integrations/connectors/destination-snowflake/src/test/resources/insert_config.json new file mode 100644 index 0000000000000..44d984364cb48 --- /dev/null +++ b/airbyte-integrations/connectors/destination-snowflake/src/test/resources/insert_config.json @@ -0,0 +1,9 @@ +{ + "host": "testhost.snowflakecomputing.com", + "role": "AIRBYTE_ROLE", + "warehouse": "AIRBYTE_WAREHOUSE", + "database": "AIRBYTE_DATABASE", + "schema": "AIRBYTE_SCHEMA", + "username": "AIRBYTE_INTEGRATION_TEST", + "password": "testPass" +} \ No newline at end of file