@@ -791,10 +791,10 @@ void testResetCancelsRunningSync() throws Exception {
791791 @ Test
792792 void testSyncAfterUpgradeToPerStreamState (final TestInfo testInfo ) throws Exception {
793793 LOGGER .info ("Starting {}" , testInfo .getDisplayName ());
794- final SourceRead source = testHarness .createPostgresSource ();
794+ final SourceRead source = testHarness .createPostgresSource (true );
795795 final UUID sourceId = source .getSourceId ();
796796 final UUID sourceDefinitionId = source .getSourceDefinitionId ();
797- final UUID destinationId = testHarness .createPostgresDestination ().getDestinationId ();
797+ final UUID destinationId = testHarness .createPostgresDestination (true ).getDestinationId ();
798798 final UUID operationId = testHarness .createOperation ().getOperationId ();
799799 final AirbyteCatalog catalog = testHarness .discoverSourceSchema (sourceId );
800800
@@ -879,10 +879,10 @@ void testSyncAfterUpgradeToPerStreamState(final TestInfo testInfo) throws Except
879879 @ Test
880880 void testSyncAfterUpgradeToPerStreamStateWithNoNewData (final TestInfo testInfo ) throws Exception {
881881 LOGGER .info ("Starting {}" , testInfo .getDisplayName ());
882- final SourceRead source = testHarness .createPostgresSource ();
882+ final SourceRead source = testHarness .createPostgresSource (true );
883883 final UUID sourceId = source .getSourceId ();
884884 final UUID sourceDefinitionId = source .getSourceDefinitionId ();
885- final UUID destinationId = testHarness .createPostgresDestination ().getDestinationId ();
885+ final UUID destinationId = testHarness .createPostgresDestination (true ).getDestinationId ();
886886 final UUID operationId = testHarness .createOperation ().getOperationId ();
887887 final AirbyteCatalog catalog = testHarness .discoverSourceSchema (sourceId );
888888
0 commit comments