fix: ConfiguredAirbyteCatalog schema violation, cursor_field can't be null

nicob3y · nicob3y · commit b51c06027acb · 2025-02-14T00:20:50.000+01:00
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -375,6 +375,7 @@ def get_configured_catalog(`
`375`	`375`	`destination_sync_mode=DestinationSyncMode.overwrite,`
`376`	`376`	`primary_key=stream.source_defined_primary_key,`
`377`	`377`	`sync_mode=SyncMode.incremental,`
	`378`	`+ cursor_field=stream.default_cursor_field,`
`378`	`379`	`)`
`379`	`380`	`for stream in self.discovered_catalog.streams`
`380`	`381`	`if stream.name in selected_streams`