File tree Expand file tree Collapse file tree 1 file changed +7
-0
lines changed
airbyte_cdk/sources/declarative/retrievers Expand file tree Collapse file tree 1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change 11import json
2+ import logging
23from pathlib import Path
34from typing import Optional
45
1112from airbyte_cdk .sources .declarative .types import Record , StreamSlice
1213from airbyte_cdk .sources .utils .files_directory import get_files_directory
1314
15+ logger = logging .getLogger ("airbyte" )
1416
1517class FileUploader :
1618 def __init__ (
@@ -54,6 +56,11 @@ def upload(self, record: Record) -> None:
5456 f .write (response .content )
5557 file_size_bytes = full_path .stat ().st_size
5658
59+ logger .info ("File uploaded successfully" )
60+ logger .info (f"File path: { full_path } " )
61+ logger .info (f"File size: { file_size_bytes / 1024 } KB" )
62+ logger .info (f"File download target: { download_target } " )
63+
5764 record .file_reference = AirbyteRecordMessageFileReference (
5865 file_url = download_target ,
5966 file_relative_path = str (file_relative_path ),
You can’t perform that action at this time.
0 commit comments