file-mode-api: make uploader updates record file_reference field

Author: aldogonzalez8

airbyte_cdk/sources/declarative/retrievers/file_uploader.py

@@ -23,7 +23,7 @@ def __init__(
         self._download_target_extractor = download_target_extractor
         self._content_extractor = content_extractor
 
-    def upload(self, record: Record) -> AirbyteRecordMessageFileReference:
+    def upload(self, record: Record) -> None:
         # TODO validate record shape - is the transformation applied at this point?
         mocked_response = SafeResponse()
         mocked_response.content = json.dumps(record.data).encode("utf-8")
@@ -54,8 +54,8 @@ def upload(self, record: Record) -> AirbyteRecordMessageFileReference:
                 f.write(response.content)
             file_size_bytes = full_path.stat().st_size
 
-        return AirbyteRecordMessageFileReference(
-            file_url=download_target,
-            file_relative_path=str(file_relative_path),
-            file_size_bytes=file_size_bytes,
-        )
+            record.file_reference = AirbyteRecordMessageFileReference(
+                file_url=download_target,
+                file_relative_path=str(file_relative_path),
+                file_size_bytes=file_size_bytes,
+            )

airbyte_cdk/sources/declarative/stream_slicers/declarative_partition_generator.py

@@ -74,8 +74,7 @@ def read(self) -> Iterable[Record]:
                     )
                 )
                 if self._file_uploader:
-                    file_reference = self._file_uploader.upload(record)
-                    record.file_reference = file_reference
+                    self._file_uploader.upload(record)
                 yield record
             else:
                 self._message_repository.emit_message(stream_data)