Skip to content

Commit 6dd3e88

Browse files
add sleep after withCdc execution
1 parent c046564 commit 6dd3e88

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

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,17 @@ public MsSQLTestDatabase(final MSSQLServerContainer<?> container) {
119119
}
120120

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

125135
public MsSQLTestDatabase withoutCdc() {

0 commit comments

Comments
 (0)