Merge branch 'main' into brian/allow_for_user_defined_cursor_fields

Author: brianjlai

airbyte_cdk/sources/file_based/file_based_stream_reader.py

@@ -207,7 +207,7 @@ def upload(
             mime_type=file.mime_type,
             created_at=file.created_at,
             updated_at=file.updated_at,
-            source_uri=file.uri,
+            source_uri=file.source_uri,
         )
         file_reference = AirbyteRecordMessageFileReference(
             staging_file_url=local_file_path,

airbyte_cdk/sources/file_based/remote_file.py

@@ -55,3 +55,10 @@ def file_uri_for_logging(self) -> str:
         Returns the URI for the file being logged.
         """
         return self.uri
+
+    @property
+    def source_uri(self) -> str:
+        """
+        Returns the Source URI for the file being logged.
+        """
+        return self.uri