Skip to content

Commit b09641b

Browse files
committed
capture manifest_list files
1 parent aaf8fc2 commit b09641b

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

pyiceberg/table/inspect.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -679,8 +679,10 @@ def orphaned_files(self, location: str, older_than: Optional[timedelta] = timede
679679
all_known_files = set()
680680
snapshots = self.tbl.snapshots()
681681
snapshot_ids = [snapshot.snapshot_id for snapshot in snapshots]
682-
manifests_paths = self.all_manifests(snapshots)["path"].to_pylist()
683-
all_known_files.update(manifests_paths)
682+
683+
all_known_files.update(self.all_manifests(snapshots)["path"].to_pylist())
684+
all_known_files.update([snapshot.manifest_list for snapshot in snapshots])
685+
all_known_files.update([statistic.statistics_path for statistic in self.tbl.metadata.statistics])
684686

685687
executor = ExecutorFactory.get_or_create()
686688
files_by_snapshots: Iterator[Set[str]] = executor.map(

0 commit comments

Comments
 (0)