From a087a9aa2315dae523f5a10e4ac74ba394d9936e Mon Sep 17 00:00:00 2001 From: darynaishchenko Date: Fri, 14 Nov 2025 15:44:36 +0200 Subject: [PATCH] add configurable source uri to UploadableRemoteFile --- airbyte_cdk/sources/file_based/file_based_stream_reader.py | 2 +- airbyte_cdk/sources/file_based/remote_file.py | 7 +++++++ 2 files changed, 8 insertions(+), 1 deletion(-) 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