Skip to content

Commit aaf8fc2

Browse files
committed
actually pass in iterable
1 parent 0c2822e commit aaf8fc2

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

pyiceberg/table/inspect.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -678,12 +678,13 @@ def orphaned_files(self, location: str, older_than: Optional[timedelta] = timede
678678

679679
all_known_files = set()
680680
snapshots = self.tbl.snapshots()
681+
snapshot_ids = [snapshot.snapshot_id for snapshot in snapshots]
681682
manifests_paths = self.all_manifests(snapshots)["path"].to_pylist()
682683
all_known_files.update(manifests_paths)
683684

684685
executor = ExecutorFactory.get_or_create()
685686
files_by_snapshots: Iterator[Set[str]] = executor.map(
686-
lambda snapshot_id: set(self.files(snapshot_id)["file_path"].to_pylist())
687+
lambda snapshot_id: set(self.files(snapshot_id)["file_path"].to_pylist()), snapshot_ids
687688
)
688689
datafile_paths: set[str] = reduce(set.union, files_by_snapshots, set())
689690
all_known_files.update(datafile_paths)

0 commit comments

Comments
 (0)