code: def _partition_selection_filter_fn(
      budget: pipeline_dp.budget_accounting.MechanismSpec,
      max_partitions: int,
      row: Tuple[
          Any, pipeline_dp.combiners.CompoundCombiner.AccumulatorType
      ],
  ) -> bool:
      """Lazily creates a partition selection strategy and uses it to determine which
      partitions to keep."""
      privacy_id_count, _ = row[1]
      partition_selection_strategy = pydp.algorithms.partition_selection.create_truncated_geometric_partition_strategy(
          budget.eps, budget.delta, max_partitions
      )
      return partition_selection_strategy.should_keep(privacy_id_count)
  
file_path: pipelinedp/utility_analysis/peeker_engine.py
imports: import functools
  from typing import Any, Sequence, Tuple, Union
  from apache_beam import pvalue
  import numpy
  import pydp
  import pipeline_dp
label_desc: Use image node_id 4 for calling a global function with example usage: _partition_selection_filter_fn(budget, max_partitions, row) and returns: partition_selection_strategy