supports_file_transfer

maxime.c · maxime.c · commit 10796293ea51 · 2025-08-06T09:52:24.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
@@ -2097,6 +2097,7 @@ def create_declarative_stream(
                 logger=logging.getLogger(f"airbyte.{stream_name}"),
                 # FIXME this is a breaking change compared to the old implementation,
                 cursor=FinalStateCursor(stream_name, None, self._message_repository),
+                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
`@@ -2097,6 +2097,7 @@ def create_declarative_stream(`
`2097`	`2097`	`logger=logging.getLogger(f"airbyte.{stream_name}"),`
`2098`	`2098`	`# FIXME this is a breaking change compared to the old implementation,`
`2099`	`2099`	`cursor=FinalStateCursor(stream_name, None, self._message_repository),`
	`2100`	`+ supports_file_transfer=hasattr(model, "file_uploader") and bool(model.file_uploader),`
`2100`	`2101`	`)`
`2101`	`2102`
`2102`	`2103`	`cursor_field = model.incremental_sync.cursor_field if model.incremental_sync else None`