We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5d9125f commit 80b7668Copy full SHA for 80b7668
airbyte_cdk/sources/file_based/file_based_stream_reader.py
@@ -207,7 +207,7 @@ def upload(
207
mime_type=file.mime_type,
208
created_at=file.created_at,
209
updated_at=file.updated_at,
210
- source_uri=file.uri,
+ source_uri=file.source_uri,
211
)
212
file_reference = AirbyteRecordMessageFileReference(
213
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:
55
Returns the URI for the file being logged.
56
"""
57
return self.uri
58
+
59
+ @property
60
+ def source_uri(self) -> str:
61
+ """
62
+ Returns the Source URI for the file being logged.
63
64
+ return self.uri
0 commit comments