no flush strategy stub.

airbytehq · Nov 20, 2024 · a5b6d0b · a5b6d0b
1 parent 3be3bf1
commit a5b6d0b
Showing 1 changed file with 0 additions and 2 deletions.
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
@@ -108,8 +108,6 @@ class SpillToDiskTaskTest {
         @Test
         fun `publishes 'spilled file' aggregates according to time window on stream flush event`() =
             runTest {
-                // flush strategy returns false, so it won't flush
-                coEvery { flushStrategy.shouldFlush(any(), any(), any()) } returns false
                 every { timeWindow.isComplete() } returns true
 
                 val flushMsg = StreamFlushEvent(101L)