working cdc with resumable full refresh

airbytehq · May 20, 2024 · d7f42b9 · d7f42b9
1 parent 1cddbdc
commit d7f42b9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../db-sources/src/main/kotlin/io/airbyte/cdk/integrations/source/jdbc/AbstractJdbcSource.kt b/.../db-sources/src/main/kotlin/io/airbyte/cdk/integrations/source/jdbc/AbstractJdbcSource.kt
@@ -135,7 +135,7 @@ abstract class AbstractJdbcSource<Datatype>(
                     ?: throw IllegalStateException(
                         "Must provide initialLoadHandler for resumable full refresh."
                     )
-            return initialLoadHandler.getIteratorForStream(airbyteStream, table, Instant.now())
+            return augmentWithStreamStatus(airbyteStream, initialLoadHandler.getIteratorForStream(airbyteStream, table, Instant.now()))
         }
 
         // If flag is off, fall back to legacy non-resumable refresh