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..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/", - filename="file.csv", + file_name="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", }