diff --git a/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py b/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py
index 731b046217050..404b7b4ab09ce 100644
--- a/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py
+++ b/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py
@@ -78,6 +78,7 @@ def create_from_stream(
                 cursor_field=cursor_field,
                 logger=logger,
                 namespace=stream.namespace,
+                cursor=cursor,
             ),
             stream,
             cursor,
diff --git a/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/cursor.py b/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/cursor.py
index a0fd47044f3d7..f91e3a16f3b94 100644
--- a/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/cursor.py
+++ b/airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/cursor.py
@@ -83,5 +83,8 @@ def observe(self, record: Record) -> None:
     def close_partition(self, partition: Partition) -> None:
         return None
 
+    def ensure_at_least_one_state_emitted(self) -> None:
+        return None
+
     def set_pending_partitions(self, partitions: Iterable[Partition]) -> None:
         return None