Skip to content

Commit 2f29eff

Browse files
fix(file-api): fix schema field for file name (#502)
1 parent fab54c2 commit 2f29eff

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

airbyte_cdk/sources/file_based/file_record_data.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ class FileRecordData(BaseModel):
1414
"""
1515

1616
folder: str
17-
filename: str
17+
file_name: str
1818
bytes: int
1919
source_uri: str
2020
id: Optional[str] = None

unit_tests/sources/file_based/stream/test_default_file_based_stream.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,7 @@ class DefaultFileBasedStreamFileTransferTest(unittest.TestCase):
285285
_NOW = datetime(2022, 10, 22, tzinfo=timezone.utc)
286286
_A_FILE_RECORD_DATA = FileRecordData(
287287
folder="/absolute/path/",
288-
filename="file.csv",
288+
file_name="file.csv",
289289
bytes=10,
290290
source_uri="file:///absolute/path/file.csv",
291291
)
@@ -337,7 +337,7 @@ def test_when_read_records_from_slice_then_return_records(self) -> None:
337337
assert list(map(lambda message: message.record.data, messages)) == [
338338
{
339339
"bytes": 10,
340-
"filename": "file.csv",
340+
"file_name": "file.csv",
341341
"folder": "/absolute/path/",
342342
"source_uri": "file:///absolute/path/file.csv",
343343
}

0 commit comments

Comments
 (0)