We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b888c56 commit ff461edCopy full SHA for ff461ed
pyiceberg/table/inspect.py
@@ -679,8 +679,8 @@ def all_known_files(self) -> dict[str, set[str]]:
679
_all_known_files["manifest_lists"] = {snapshot.manifest_list for snapshot in snapshots}
680
_all_known_files["statistics"] = {statistic.statistics_path for statistic in self.tbl.metadata.statistics}
681
682
- snapshot_ids = [snapshot.snapshot_id for snapshot in snapshots]
683
executor = ExecutorFactory.get_or_create()
+ snapshot_ids = [snapshot.snapshot_id for snapshot in snapshots]
684
files_by_snapshots: Iterator[Set[str]] = executor.map(
685
lambda snapshot_id: set(self.files(snapshot_id)["file_path"].to_pylist()), snapshot_ids
686
)
0 commit comments