Skip to content

Commit 290f99e

Browse files
committed
Make scan_plan_helper internal (#3541)
scan_plan_helper is an internal helper for local scan planning, not a public extension point. Rename it to _scan_plan_helper to reflect its intended visibility and update its only caller in inspect.py. The method was introduced recently in d99936a and has not been part of any released public API, so no deprecation shim is required.
1 parent b8ffdd3 commit 290f99e

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

‎pyiceberg/table/__init__.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2110,7 +2110,7 @@ def _manifest_planner(self) -> ManifestGroupPlanner:
21102110
def partition_filters(self) -> KeyDefaultDict[int, BooleanExpression]:
21112111
return self._manifest_planner.partition_filters
21122112

2113-
def scan_plan_helper(self) -> Iterator[list[ManifestEntry]]:
2113+
def _scan_plan_helper(self) -> Iterator[list[ManifestEntry]]:
21142114
"""Filter and return manifest entries based on partition and metrics evaluators.
21152115
21162116
Returns:

‎pyiceberg/table/inspect.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,7 @@ def partitions(
311311

312312
partitions_map: dict[tuple[str, Any], Any] = {}
313313

314-
for entry in itertools.chain.from_iterable(scan.scan_plan_helper()):
314+
for entry in itertools.chain.from_iterable(scan._scan_plan_helper()):
315315
partition = entry.data_file.partition
316316
partition_record_dict = {
317317
field.name: partition[pos] for pos, field in enumerate(self.tbl.metadata.specs()[entry.data_file.spec_id].fields)

0 commit comments

Comments
 (0)