Skip to content

Commit 312d7e0

Browse files
committed
work with correct schema
1 parent d2c58b2 commit 312d7e0

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

pyiceberg/table/inspect.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -722,10 +722,17 @@ def position_deletes(self, snapshot_id: Optional[int] = None) -> "pa.Table":
722722
schema = self._get_positional_deletes_schema()
723723
return pa.Table.from_pylist([], schema=schema)
724724

725+
if not snapshot.schema_id:
726+
raise ValueError(f"Snapshot {snapshot.snapshot_id} does not have a schema id")
727+
725728
schemas = self.tbl.schemas()
729+
schema = schemas.get(snapshot.schema_id, None)
730+
if not schema:
731+
raise ValueError(f"Cannot find schema with id: {snapshot.schema_id}")
732+
726733
executor = ExecutorFactory.get_or_create()
727734
positional_deletes: Iterator["pa.Table"] = executor.map(
728-
lambda manifest: self._generate_positional_delete_table(manifest, schema=schemas[snapshot.schema_id]),
735+
lambda manifest: self._generate_positional_delete_table(manifest, schema=schema),
729736
snapshot.manifests(self.tbl.io),
730737
)
731738
return pa.concat_tables(positional_deletes)

0 commit comments

Comments
 (0)