diff --git a/pyiceberg/manifest.py b/pyiceberg/manifest.py index 2b54fff509..53e7a2e1e3 100644 --- a/pyiceberg/manifest.py +++ b/pyiceberg/manifest.py @@ -306,6 +306,13 @@ def __repr__(self) -> str: required=False, doc="ID representing sort order for this file", ), + NestedField( + field_id=143, + name="referenced_data_file", + field_type=StringType(), + required=False, + doc="Fully qualified location (URI with FS scheme) of a data file that all deletes reference", + ), ), 3: StructType( NestedField( diff --git a/tests/avro/test_file.py b/tests/avro/test_file.py index 7bd0422439..66d9e3bad7 100644 --- a/tests/avro/test_file.py +++ b/tests/avro/test_file.py @@ -225,7 +225,7 @@ def test_write_manifest_entry_with_iceberg_read_with_fastavro_v2() -> None: fa_entry = next(it) v2_entry = todict(entry) - for field in ("first_row_id", "referenced_data_file", "content_offset", "content_size_in_bytes"): + for field in ("first_row_id", "content_offset", "content_size_in_bytes"): del v2_entry["data_file"][field] assert v2_entry == fa_entry diff --git a/tests/integration/test_rest_manifest.py b/tests/integration/test_rest_manifest.py index 5ca9f22a8c..21832116b5 100644 --- a/tests/integration/test_rest_manifest.py +++ b/tests/integration/test_rest_manifest.py @@ -112,7 +112,7 @@ def test_write_sample_manifest(table_test_all_types: Table, compression: AvroCom wrapped_entry_v2 = copy(entry) wrapped_entry_v2.data_file = wrapped_data_file_v2_debug wrapped_entry_v2_dict = todict(wrapped_entry_v2, [field.name for field in test_spec.fields]) - for field in ("first_row_id", "referenced_data_file", "content_offset", "content_size_in_bytes"): + for field in ("first_row_id", "content_offset", "content_size_in_bytes"): del wrapped_entry_v2_dict["data_file"][field] with TemporaryDirectory() as tmpdir: