diff --git a/airbyte-integrations/connectors/source-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java b/airbyte-integrations/connectors/source-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java index 485dfe11e3c0..fec850808032 100644 --- a/airbyte-integrations/connectors/source-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java +++ b/airbyte-integrations/connectors/source-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 tableNames = actual.getStreams().stream().map(stream -> stream.getName()).collect(Collectors.toSet()); final Set expectedVisibleNames = Sets.newHashSet( "table_granted_by_role",