From b51c06027acbf6d7238285bb263bfcf82aff1a32 Mon Sep 17 00:00:00 2001 From: Nicolas Date: Fri, 14 Feb 2025 00:20:50 +0100 Subject: [PATCH] fix: ConfiguredAirbyteCatalog schema violation, cursor_field can't be null --- airbyte/sources/base.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airbyte/sources/base.py b/airbyte/sources/base.py index 638ff715..23f51a2e 100644 --- a/airbyte/sources/base.py +++ b/airbyte/sources/base.py @@ -375,6 +375,7 @@ def get_configured_catalog( destination_sync_mode=DestinationSyncMode.overwrite, primary_key=stream.source_defined_primary_key, sync_mode=SyncMode.incremental, + cursor_field=stream.default_cursor_field, ) for stream in self.discovered_catalog.streams if stream.name in selected_streams