format

maxime.c · maxime.c · commit 7f643e4be73a · 2025-08-06T10:27:46.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,7 +2097,8 @@ 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),
+                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,7 +2097,8 @@ 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`	`+ supports_file_transfer=hasattr(model, "file_uploader")`
	`2101`	`+ and bool(model.file_uploader),`
`2101`	`2102`	`)`
`2102`	`2103`
`2103`	`2104`	`cursor_field = model.incremental_sync.cursor_field if model.incremental_sync else None`