File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
airbyte_cdk/sources/file_based/file_types Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 77from airbyte_cdk .models import AirbyteRecordMessageFileReference
88from airbyte_cdk .sources .file_based .file_based_stream_reader import AbstractFileBasedStreamReader
99from airbyte_cdk .sources .file_based .file_record_data import FileRecordData
10- from airbyte_cdk .sources .file_based .remote_file import RemoteFile
10+ from airbyte_cdk .sources .file_based .remote_file import UploadableRemoteFile
1111from airbyte_cdk .sources .utils .files_directory import get_files_directory
1212
1313
@@ -17,7 +17,7 @@ def __init__(self) -> None:
1717
1818 def upload (
1919 self ,
20- file : RemoteFile ,
20+ file : UploadableRemoteFile ,
2121 stream_reader : AbstractFileBasedStreamReader ,
2222 logger : logging .Logger ,
2323 ) -> Iterable [Tuple [FileRecordData , AirbyteRecordMessageFileReference ]]:
You can’t perform that action at this time.
0 commit comments