Revert a change made to enhance snowflake test stability as it broke …

…other tests. (#21494)
airbytehq · Jan 17, 2023 · 967c428 · 967c428
1 parent 2c3be39
commit 967c428
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...main/java/io/airbyte/integrations/standardtest/source/AbstractSourceDatabaseTypeTest.java b/...main/java/io/airbyte/integrations/standardtest/source/AbstractSourceDatabaseTypeTest.java
@@ -111,9 +111,7 @@ public void testDataTypes() throws Exception {
     final List<AirbyteMessage> allMessages = runRead(catalog);
     final UUID catalogId = runDiscover();
     final Map<String, AirbyteStream> streams = getLastPersistedCatalog().getStreams().stream()
-        .collect(Collectors.toMap(
-            s -> "%s.%s".formatted(s.getNamespace(), s.getName()),
-            s -> s));
+        .collect(Collectors.toMap(AirbyteStream::getName, s -> s));
     final List<AirbyteMessage> recordMessages = allMessages.stream().filter(m -> m.getType() == Type.RECORD).toList();
     final Map<String, List<String>> expectedValues = new HashMap<>();
     testDataHolders.forEach(testDataHolder -> {