File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -2110,11 +2110,11 @@ def create_default_stream(
21102110 name = stream_name ,
21112111 json_schema = schema_loader .get_json_schema ,
21122112 primary_key = get_primary_key_from_stream (primary_key ),
2113- cursor_field = concurrent_cursor . cursor_field
2114- if hasattr ( concurrent_cursor , " cursor_field" )
2115- else CursorField (
2116- cursor_field_key = ""
2117- ), # FIXME we should have the cursor field has part of the interface of cursor,
2113+ cursor_field = (
2114+ concurrent_cursor . cursor_field
2115+ if hasattr ( concurrent_cursor , "cursor_field" )
2116+ else None
2117+ ),
21182118 logger = logging .getLogger (f"airbyte.{ stream_name } " ),
21192119 cursor = concurrent_cursor ,
21202120 supports_file_transfer = hasattr (model , "file_uploader" ) and bool (model .file_uploader ),
You can’t perform that action at this time.
0 commit comments