add test

jhammarstedt · Sep 26, 2022 · 38eea09 · 38eea09
1 parent 72ca5d9
commit 38eea09
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...ce-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java b/...ce-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java
@@ -432,6 +432,11 @@ void testDiscoverDifferentGrantAvailability() throws Exception {
       }
 
       final AirbyteCatalog actual = new PostgresSource().discover(getConfig(db, "new_test_user", "new_pass"));
+      actual.getStreams().stream().forEach(airbyteStream -> {
+        assertEquals(2, airbyteStream.getSupportedSyncModes().size());
+        assertTrue(airbyteStream.getSupportedSyncModes().contains(SyncMode.FULL_REFRESH));
+        assertTrue(airbyteStream.getSupportedSyncModes().contains(SyncMode.INCREMENTAL));
+      });
       final Set<String> tableNames = actual.getStreams().stream().map(stream -> stream.getName()).collect(Collectors.toSet());
       final Set<String> expectedVisibleNames = Sets.newHashSet(
           "table_granted_by_role",