code: def _per_partition_bounding(
      max_contributions_per_partition: int,
      pk: Any,
      pval: int,
      pcount: int,
  ) -> Tuple[Any, int]:
      del pcount  # unused
      bounded_value = min(pval, max_contributions_per_partition)
      return pk, bounded_value
  
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 3 for calling a global function with example usage: _per_partition_bounding(max_contributions_per_partition, pk, pval, pcount) and returns: pk,  bounded_value