From ccc306b87166955985cef85e8fd24452f52e94bf Mon Sep 17 00:00:00 2001 From: Davin Chia Date: Mon, 21 Aug 2023 16:55:34 -0700 Subject: [PATCH] Also clean up namespaces. --- .../standardtest/destination/DestinationAcceptanceTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/bases/standard-destination-test/src/main/java/io/airbyte/integrations/standardtest/destination/DestinationAcceptanceTest.java b/airbyte-integrations/bases/standard-destination-test/src/main/java/io/airbyte/integrations/standardtest/destination/DestinationAcceptanceTest.java index 9055a2d20a2b..18c06ec43e26 100644 --- a/airbyte-integrations/bases/standard-destination-test/src/main/java/io/airbyte/integrations/standardtest/destination/DestinationAcceptanceTest.java +++ b/airbyte-integrations/bases/standard-destination-test/src/main/java/io/airbyte/integrations/standardtest/destination/DestinationAcceptanceTest.java @@ -1082,12 +1082,13 @@ public void testNamespaces(final String testCaseId, DataArgumentsProvider.NAMESPACE_CONFIG.getMessageFileVersion(getProtocolVersion())).lines() .map(record -> Jsons.deserialize(record, AirbyteMessage.class)) .collect(Collectors.toList()); - final List messagesWithNewNamespace = getRecordMessagesWithNewNamespace( - messages, namespace); + final List messagesWithNewNamespace = getRecordMessagesWithNewNamespace(messages, namespace); final JsonNode config = getConfig(); try { runSyncAndVerifyStateOutput(config, messagesWithNewNamespace, configuredCatalog, false); + // Add to the list of schemas to clean up. + TEST_SCHEMAS.add(namespace); } catch (final Exception e) { throw new IOException(String.format( "[Test Case %s] Destination failed to sync data to namespace %s, see \"namespace_test_cases.json for details\"",