Skip to content

Commit a43877f

Browse files
committed
work with correct schema
1 parent 58b7fa5 commit a43877f

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
@@ -769,10 +769,17 @@ def position_deletes(self, snapshot_id: Optional[int] = None) -> "pa.Table":
769769
schema = self._get_positional_deletes_schema()
770770
return pa.Table.from_pylist([], schema=schema)
771771

772+
if not snapshot.schema_id:
773+
raise ValueError(f"Snapshot {snapshot.snapshot_id} does not have a schema id")
774+
772775
schemas = self.tbl.schemas()
776+
schema = schemas.get(snapshot.schema_id, None)
777+
if not schema:
778+
raise ValueError(f"Cannot find schema with id: {snapshot.schema_id}")
779+
773780
executor = ExecutorFactory.get_or_create()
774781
positional_deletes: Iterator["pa.Table"] = executor.map(
775-
lambda manifest: self._generate_positional_delete_table(manifest, schema=schemas[snapshot.schema_id]),
782+
lambda manifest: self._generate_positional_delete_table(manifest, schema=schema),
776783
snapshot.manifests(self.tbl.io),
777784
)
778785
return pa.concat_tables(positional_deletes)

0 commit comments

Comments
 (0)