Merge branch 'maxi297/bland_stream_instantiated_as_defaultstream' into maxi297/incremental_without_partition_router_as_defaultstream

maxime.c · maxime.c · commit 856660793640 · 2025-08-06T10:28:42.000-04:00
diff --git a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -2107,7 +2107,8 @@ def create_declarative_stream(
                 logger=logging.getLogger(f"airbyte.{stream_name}"),
                 # FIXME this is a breaking change compared to the old implementation which used the source name instead
                 cursor=cursor,
-                supports_file_transfer=hasattr(model, "file_uploader") and bool(model.file_uploader),
+                supports_file_transfer=hasattr(model, "file_uploader")
+                and bool(model.file_uploader),
             )
 
         cursor_field = model.incremental_sync.cursor_field if model.incremental_sync else None

Original file line number	Diff line number	Diff line change
`@@ -2107,7 +2107,8 @@ def create_declarative_stream(`
`2107`	`2107`	`logger=logging.getLogger(f"airbyte.{stream_name}"),`
`2108`	`2108`	`# FIXME this is a breaking change compared to the old implementation which used the source name instead`
`2109`	`2109`	`cursor=cursor,`
`2110`		`- supports_file_transfer=hasattr(model, "file_uploader") and bool(model.file_uploader),`
	`2110`	`+ supports_file_transfer=hasattr(model, "file_uploader")`
	`2111`	`+ and bool(model.file_uploader),`
`2111`	`2112`	`)`
`2112`	`2113`
`2113`	`2114`	`cursor_field = model.incremental_sync.cursor_field if model.incremental_sync else None`