Merge branch 'maxi297/bland_stream_instantiated_as_defaultstream' into maxi297/incremental_without_partition_router_as_defaultstream

maxime.c · maxime.c · commit f196ea7d6cd0 · 2025-08-06T09:53:36.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,6 +2107,7 @@ 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),
             )
 
         cursor_field = model.incremental_sync.cursor_field if model.incremental_sync else None

Original file line number	Diff line number	Diff line change
`@@ -2107,6 +2107,7 @@ 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`	`2111`	`)`
`2111`	`2112`
`2112`	`2113`	`cursor_field = model.incremental_sync.cursor_field if model.incremental_sync else None`