file-mode-api: add new file_reference in the FileBasedStreamFacade when yielding record

aldogonzalez8 · aldogonzalez8 · commit 6db04065ffea · 2025-04-07T05:33:04.000-06:00
diff --git a/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py b/airbyte_cdk/sources/file_based/stream/concurrent/adapters.py
@@ -265,6 +265,7 @@ def read(self) -> Iterable[Record]:
                         yield Record(
                             data=record_message_data,
                             stream_name=self.stream_name(),
+                            file_reference=record_data.record.file_reference,
                         )
                 else:
                     self._message_repository.emit_message(record_data)

Original file line number	Diff line number	Diff line change
`@@ -265,6 +265,7 @@ def read(self) -> Iterable[Record]:`
`265`	`265`	`yield Record(`
`266`	`266`	`data=record_message_data,`
`267`	`267`	`stream_name=self.stream_name(),`
	`268`	`+ file_reference=record_data.record.file_reference,`
`268`	`269`	`)`
`269`	`270`	`else:`
`270`	`271`	`self._message_repository.emit_message(record_data)`