Skip to content

Commit d0b2110

Browse files
more. attempts at fixing tests
1 parent ddea01a commit d0b2110

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

airbyte-integrations/connectors/source-mssql/src/test/java/io/airbyte/integrations/source/mssql/CdcMssqlSourceTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ protected void setup() {
143143
\t@source_name = N'%s',
144144
\t@role_name = N'%s',
145145
\t@supports_net_changes = 0""";
146-
testdb
146+
testdb.withCdc()
147147
.with(enableCdcSqlFmt, modelsSchema(), MODELS_STREAM_NAME, CDC_ROLE_NAME)
148148
.with(enableCdcSqlFmt, randomSchema(), RANDOM_TABLE_NAME, CDC_ROLE_NAME)
149149
.withShortenedCapturePollingInterval();

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,7 @@ public void run() {
7777
while (status == Status.INITIALIZING) {
7878
// Loop until running. This is a busy loop because I want to execute the query below ASAP
7979
}
80+
LOGGER.info("SGX databaseId=" + databaseId + ". Database initialized " + getDatabaseName());
8081
Status myStatus = status;
8182
boolean wasRunning = false;
8283
try {
@@ -114,6 +115,7 @@ public void run() {
114115

115116
public MsSQLTestDatabase(final MSSQLServerContainer<?> container) {
116117
super(container);
118+
LOGGER.info("SGX creating new database. databaseId=" + this.databaseId + ", databaseName=" + getDatabaseName());
117119
new MssqlTestDatabaseBackgroundThread().start();
118120
}
119121

0 commit comments

Comments
 (0)