diff --git a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py index 88ff142c7a..d83a054421 100644 --- a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py +++ b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py @@ -2110,11 +2110,11 @@ def create_default_stream( name=stream_name, json_schema=schema_loader.get_json_schema, primary_key=get_primary_key_from_stream(primary_key), - cursor_field=concurrent_cursor.cursor_field - if hasattr(concurrent_cursor, "cursor_field") - else CursorField( - cursor_field_key="" - ), # FIXME we should have the cursor field has part of the interface of cursor, + cursor_field=( + concurrent_cursor.cursor_field + if hasattr(concurrent_cursor, "cursor_field") + else None + ), logger=logging.getLogger(f"airbyte.{stream_name}"), cursor=concurrent_cursor, supports_file_transfer=hasattr(model, "file_uploader") and bool(model.file_uploader),