Skip to content

Commit c26d355

Browse files
authored
Fix Cursor interface change + FileBased change at the same time (#34653)
1 parent 05a55f0 commit c26d355

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ def create_from_stream(
7878
cursor_field=cursor_field,
7979
logger=logger,
8080
namespace=stream.namespace,
81+
cursor=cursor,
8182
),
8283
stream,
8384
cursor,

airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/concurrent/cursor.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,5 +83,8 @@ def observe(self, record: Record) -> None:
8383
def close_partition(self, partition: Partition) -> None:
8484
return None
8585

86+
def ensure_at_least_one_state_emitted(self) -> None:
87+
return None
88+
8689
def set_pending_partitions(self, partitions: Iterable[Partition]) -> None:
8790
return None

0 commit comments

Comments
 (0)