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