Skip to content

Commit 459f923

Browse files
add sleep after withCdc execution
1 parent 1e33870 commit 459f923

File tree

1 file changed

+11
-1
lines changed
  • airbyte-integrations/connectors/source-mssql/src/testFixtures/java/io/airbyte/integrations/source/mssql

1 file changed

+11
-1
lines changed

airbyte-integrations/connectors/source-mssql/src/testFixtures/java/io/airbyte/integrations/source/mssql/MsSQLTestDatabase.java

+11-1
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,17 @@ public void initializedPostHook() {
118118
}
119119

120120
public MsSQLTestDatabase withCdc() {
121-
return with("EXEC sys.sp_cdc_enable_db;");
121+
LOGGER.info("enabling CDC on database {} with id {}", getDatabaseName(), databaseId);
122+
MsSQLTestDatabase retVal = with("EXEC sys.sp_cdc_enable_db;");
123+
LOGGER.info("CDC enabled on database {} with id {}", getDatabaseName(), databaseId);
124+
try {
125+
LOGGER.info("Sleeping");
126+
Thread.sleep(60_000);
127+
LOGGER.info("Done sleeping");
128+
} catch (InterruptedException e) {
129+
130+
}
131+
return retVal;
122132
}
123133

124134
public MsSQLTestDatabase withoutCdc() {

0 commit comments

Comments
 (0)