From ef12f55149c2377c59a24fdd3241e1535068ff17 Mon Sep 17 00:00:00 2001 From: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> Date: Thu, 8 Jan 2026 21:02:29 +0000 Subject: [PATCH 1/2] fix: do not advertise incremental sync mode for streams without cursor field Co-Authored-By: AJ Steers --- .../sources/declarative/parsers/model_to_component_factory.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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..c6fb3496cd 100644 --- a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py +++ b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py @@ -2112,9 +2112,7 @@ def create_default_stream( 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, + else None, logger=logging.getLogger(f"airbyte.{stream_name}"), cursor=concurrent_cursor, supports_file_transfer=hasattr(model, "file_uploader") and bool(model.file_uploader), From 3c36c8eeef15b1d12a4316e5268f0ae46c4f4fd7 Mon Sep 17 00:00:00 2001 From: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> Date: Thu, 8 Jan 2026 21:04:00 +0000 Subject: [PATCH 2/2] style: wrap ternary expression in parentheses for better readability Co-Authored-By: AJ Steers --- .../declarative/parsers/model_to_component_factory.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) 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 c6fb3496cd..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,9 +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 None, + 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),