Fix.

airbytehq · Nov 20, 2024 · 3be3bf1 · 3be3bf1
1 parent 62ccaf8
commit 3be3bf1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...k/bulk/core/load/src/test/kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTaskTest.kt b/...k/bulk/core/load/src/test/kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTaskTest.kt
@@ -29,6 +29,7 @@ import io.airbyte.cdk.load.test.util.StubDestinationMessageFactory
 import io.airbyte.cdk.load.util.lineSequence
 import io.mockk.coEvery
 import io.mockk.coVerify
+import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension
 import io.mockk.mockk
@@ -109,7 +110,7 @@ class SpillToDiskTaskTest {
             runTest {
                 // flush strategy returns false, so it won't flush
                 coEvery { flushStrategy.shouldFlush(any(), any(), any()) } returns false
-                coEvery { timeWindow.isComplete() } returns true
+                every { timeWindow.isComplete() } returns true
 
                 val flushMsg = StreamFlushEvent(101L)
                 val recordMsg =