Skip to content

Commit ae6db5a

Browse files
authored
Fix reversed assertions in MySQL source tests (#55756)
1 parent 9f9bcdc commit ae6db5a

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

airbyte-integrations/connectors/source-mysql/src/test/kotlin/io/airbyte/integrations/source/mysql/MySqlSourceCdcIntegrationTest.kt

+3-3
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,10 @@ class MySqlSourceCdcIntegrationTest {
3737
fun testCheck() {
3838
val run1: BufferingOutputConsumer = CliRunner.source("check", config(), null).run()
3939

40-
assertEquals(run1.messages().size, 1)
40+
assertEquals(1, run1.messages().size)
4141
assertEquals(
42-
run1.messages().first().connectionStatus.status,
43-
AirbyteConnectionStatus.Status.SUCCEEDED
42+
AirbyteConnectionStatus.Status.SUCCEEDED,
43+
run1.messages().first().connectionStatus.status
4444
)
4545

4646
MySqlContainerFactory.exclusive(

airbyte-integrations/connectors/source-mysql/src/test/kotlin/io/airbyte/integrations/source/mysql/MySqlSourceCursorBasedIntegrationTest.kt

+5-5
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ class MySqlSourceCursorBasedIntegrationTest {
7676
val run2: BufferingOutputConsumer =
7777
CliRunner.source("read", config, getConfiguredCatalog(), run2InputState).run()
7878
val recordMessageFromRun2: List<AirbyteRecordMessage> = run2.records()
79-
assertEquals(recordMessageFromRun2.size, 1)
79+
assertEquals(1, recordMessageFromRun2.size)
8080
}
8181

8282
@Test
@@ -85,7 +85,7 @@ class MySqlSourceCursorBasedIntegrationTest {
8585
val run1: BufferingOutputConsumer =
8686
CliRunner.source("read", config, getConfiguredCatalog(), listOf(state)).run()
8787
val recordMessageFromRun1: List<AirbyteRecordMessage> = run1.records()
88-
assertEquals(recordMessageFromRun1.size, 1)
88+
assertEquals(1, recordMessageFromRun1.size)
8989
}
9090

9191
@Test
@@ -95,7 +95,7 @@ class MySqlSourceCursorBasedIntegrationTest {
9595
val run1: BufferingOutputConsumer =
9696
CliRunner.source("read", config, getConfiguredCatalog(), listOf(state)).run()
9797
val recordMessageFromRun1: List<AirbyteRecordMessage> = run1.records()
98-
assertEquals(recordMessageFromRun1.size, 2)
98+
assertEquals(2, recordMessageFromRun1.size)
9999
}
100100

101101
@Test
@@ -105,14 +105,14 @@ class MySqlSourceCursorBasedIntegrationTest {
105105
val run1: BufferingOutputConsumer =
106106
CliRunner.source("read", config, fullRefreshCatalog).run()
107107
val recordMessageFromRun1: List<AirbyteRecordMessage> = run1.records()
108-
assertEquals(recordMessageFromRun1.size, 2)
108+
assertEquals(2, recordMessageFromRun1.size)
109109
val lastStateMessageFromRun1 = run1.states().last()
110110

111111
val run2: BufferingOutputConsumer =
112112
CliRunner.source("read", config, fullRefreshCatalog, listOf(lastStateMessageFromRun1))
113113
.run()
114114
val recordMessageFromRun2: List<AirbyteRecordMessage> = run2.records()
115-
assertEquals(recordMessageFromRun2.size, 0)
115+
assertEquals(0, recordMessageFromRun2.size)
116116
}
117117

118118
@Test

0 commit comments

Comments
 (0)