diff --git a/airbyte_cdk/sources/file_based/file_based_stream_reader.py b/airbyte_cdk/sources/file_based/file_based_stream_reader.py index f97bc3f9a..7443dccd6 100644 --- a/airbyte_cdk/sources/file_based/file_based_stream_reader.py +++ b/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, diff --git a/airbyte_cdk/sources/file_based/remote_file.py b/airbyte_cdk/sources/file_based/remote_file.py index b2bfb23f5..00669fbba 100644 --- a/airbyte_cdk/sources/file_based/remote_file.py +++ b/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