Skip to content

Commit 682318e

Browse files
committed
file-mode-api: bump protocol to latest pre-dev
1 parent 69b7835 commit 682318e

File tree

4 files changed

+10
-12
lines changed

4 files changed

+10
-12
lines changed

airbyte_cdk/sources/file_based/file_based_stream_reader.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -164,11 +164,9 @@ def upload(
164164
165165
Returns:
166166
AirbyteRecordMessageFileReference: A file reference object containing:
167-
- file_url (str): The absolute path of the downloaded file.
168-
- bytes (int): The file size in bytes.
169-
- file_relative_path (str): The relative path of the file for local storage. Is relative to local_directory as
170-
this a mounted volume in the pod container.
171-
167+
- staging_file_url (str): The absolute path to the referenced file in the staging area.
168+
- file_size_bytes (int): The size of the referenced file in bytes.
169+
- source_file_relative_path (str): The relative path to the referenced file in source.
172170
"""
173171
...
174172

poetry.lock

Lines changed: 4 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ enable = true
3030

3131
[tool.poetry.dependencies]
3232
python = ">=3.10,<3.13"
33-
airbyte-protocol-models-dataclasses = { version = "0.14.1337.dev1742858109", source = "testpypi" }
33+
airbyte-protocol-models-dataclasses = { version = "0.14.4.dev1743719077", source = "testpypi" }
3434

3535
backoff = "*"
3636
cachetools = "*"

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
@@ -282,8 +282,8 @@ class DefaultFileBasedStreamFileTransferTest(unittest.TestCase):
282282
_NOW = datetime(2022, 10, 22, tzinfo=timezone.utc)
283283
_A_FILE_REFERENCE_MESSAGE = AirbyteRecordMessageFileReference(
284284
file_size_bytes=10,
285-
file_relative_path="relative/path/file.csv",
286-
file_url="/absolute/path/file.csv",
285+
source_file_relative_path="relative/path/file.csv",
286+
staging_file_url="/absolute/path/file.csv",
287287
)
288288

289289
def setUp(self) -> None:

0 commit comments

Comments
 (0)