From 5de055d56945cbf7464bc366d91c98754b7ac52b Mon Sep 17 00:00:00 2001 From: Aldo Gonzalez Date: Tue, 22 Apr 2025 13:48:38 -0700 Subject: [PATCH 1/2] file-api: fix schema field for file name --- airbyte_cdk/sources/file_based/file_record_data.py | 2 +- .../file_based/stream/test_default_file_based_stream.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/airbyte_cdk/sources/file_based/file_record_data.py b/airbyte_cdk/sources/file_based/file_record_data.py index 7051cf057..560e5a8cc 100644 --- a/airbyte_cdk/sources/file_based/file_record_data.py +++ b/airbyte_cdk/sources/file_based/file_record_data.py @@ -14,7 +14,7 @@ class FileRecordData(BaseModel): """ folder: str - filename: str + file_name: str bytes: int source_uri: str id: Optional[str] = None diff --git a/unit_tests/sources/file_based/stream/test_default_file_based_stream.py b/unit_tests/sources/file_based/stream/test_default_file_based_stream.py index 55191d7f6..c4ebbf081 100644 --- a/unit_tests/sources/file_based/stream/test_default_file_based_stream.py +++ b/unit_tests/sources/file_based/stream/test_default_file_based_stream.py @@ -285,7 +285,7 @@ class DefaultFileBasedStreamFileTransferTest(unittest.TestCase): _NOW = datetime(2022, 10, 22, tzinfo=timezone.utc) _A_FILE_RECORD_DATA = FileRecordData( folder="/absolute/path/", - filename="file.csv", + filen_ame="file.csv", bytes=10, source_uri="file:///absolute/path/file.csv", ) @@ -337,7 +337,7 @@ def test_when_read_records_from_slice_then_return_records(self) -> None: assert list(map(lambda message: message.record.data, messages)) == [ { "bytes": 10, - "filename": "file.csv", + "file_name": "file.csv", "folder": "/absolute/path/", "source_uri": "file:///absolute/path/file.csv", } From f68547bf624bbbc024c401fd1c04722ac87c4b3f Mon Sep 17 00:00:00 2001 From: Aldo Gonzalez Date: Tue, 22 Apr 2025 13:57:07 -0700 Subject: [PATCH 2/2] file-api: fix typo --- .../sources/file_based/stream/test_default_file_based_stream.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/unit_tests/sources/file_based/stream/test_default_file_based_stream.py b/unit_tests/sources/file_based/stream/test_default_file_based_stream.py index c4ebbf081..60716b771 100644 --- a/unit_tests/sources/file_based/stream/test_default_file_based_stream.py +++ b/unit_tests/sources/file_based/stream/test_default_file_based_stream.py @@ -285,7 +285,7 @@ class DefaultFileBasedStreamFileTransferTest(unittest.TestCase): _NOW = datetime(2022, 10, 22, tzinfo=timezone.utc) _A_FILE_RECORD_DATA = FileRecordData( folder="/absolute/path/", - filen_ame="file.csv", + file_name="file.csv", bytes=10, source_uri="file:///absolute/path/file.csv", )