jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-23 21:03:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix reversed assertions in MySQL source tests (#55756)

Browse Source
This commit is contained in:
Wenqi Hu
2025-03-13 13:28:54 -07:00
committed by GitHub
parent 9f9bcdcbdf
commit ae6db5ad2c
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -37,10 +37,10 @@ class MySqlSourceCdcIntegrationTest {
fun testCheck() {
val run1: BufferingOutputConsumer = CliRunner.source("check", config(), null).run()
assertEquals(run1.messages().size, 1)
assertEquals(1, run1.messages().size)
assertEquals(
run1.messages().first().connectionStatus.status,
AirbyteConnectionStatus.Status.SUCCEEDED
AirbyteConnectionStatus.Status.SUCCEEDED,
run1.messages().first().connectionStatus.status
)
MySqlContainerFactory.exclusive(

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

@@ -76,7 +76,7 @@ class MySqlSourceCursorBasedIntegrationTest {
val run2: BufferingOutputConsumer =
CliRunner.source("read", config, getConfiguredCatalog(), run2InputState).run()
val recordMessageFromRun2: List<AirbyteRecordMessage> = run2.records()
assertEquals(recordMessageFromRun2.size, 1)
assertEquals(1, recordMessageFromRun2.size)
}
@Test
@@ -85,7 +85,7 @@ class MySqlSourceCursorBasedIntegrationTest {
val run1: BufferingOutputConsumer =
CliRunner.source("read", config, getConfiguredCatalog(), listOf(state)).run()
val recordMessageFromRun1: List<AirbyteRecordMessage> = run1.records()
assertEquals(recordMessageFromRun1.size, 1)
assertEquals(1, recordMessageFromRun1.size)
}
@Test
@@ -95,7 +95,7 @@ class MySqlSourceCursorBasedIntegrationTest {
val run1: BufferingOutputConsumer =
CliRunner.source("read", config, getConfiguredCatalog(), listOf(state)).run()
val recordMessageFromRun1: List<AirbyteRecordMessage> = run1.records()
assertEquals(recordMessageFromRun1.size, 2)
assertEquals(2, recordMessageFromRun1.size)
}
@Test
@@ -105,14 +105,14 @@ class MySqlSourceCursorBasedIntegrationTest {
val run1: BufferingOutputConsumer =
CliRunner.source("read", config, fullRefreshCatalog).run()
val recordMessageFromRun1: List<AirbyteRecordMessage> = run1.records()
assertEquals(recordMessageFromRun1.size, 2)
assertEquals(2, recordMessageFromRun1.size)
val lastStateMessageFromRun1 = run1.states().last()
val run2: BufferingOutputConsumer =
CliRunner.source("read", config, fullRefreshCatalog, listOf(lastStateMessageFromRun1))
.run()
val recordMessageFromRun2: List<AirbyteRecordMessage> = run2.records()
assertEquals(recordMessageFromRun2.size, 0)
assertEquals(0, recordMessageFromRun2.size)
}
@Test