Revert "Improve DAT: Random namespace to avoid namespace collision. (#…

…29652)" This reverts commit ec3fb40.
airbytehq · Aug 22, 2023 · da030a2 · da030a2
1 parent e321b9e
commit da030a2
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/...main/java/io/airbyte/integrations/standardtest/destination/DestinationAcceptanceTest.java b/...main/java/io/airbyte/integrations/standardtest/destination/DestinationAcceptanceTest.java
@@ -1082,13 +1082,12 @@ public void testNamespaces(final String testCaseId,
         DataArgumentsProvider.NAMESPACE_CONFIG.getMessageFileVersion(getProtocolVersion())).lines()
         .map(record -> Jsons.deserialize(record, AirbyteMessage.class))
         .collect(Collectors.toList());
-    final List<AirbyteMessage> messagesWithNewNamespace = getRecordMessagesWithNewNamespace(messages, namespace);
+    final List<AirbyteMessage> 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\"",
@@ -1806,8 +1805,7 @@ public Stream<? extends Arguments> provideArguments(final ExtensionContext conte
           .filter(testCase -> testCase.get("enabled").asBoolean())
           .map(testCase -> Arguments.of(
               testCase.get("id").asText(),
-              // Randomise namespace to avoid collisions between tests.
-              Strings.addRandomSuffix(testCase.get("namespace").asText(), "", 5),
+              testCase.get("namespace").asText(),
               testCase.get("normalized").asText()));
     }