code: def test_partition_sampling(self, mock_sampler_init):
      # Arrange
      mock_sampler_init.return_value = None
      aggregator_params = self._get_default_aggregate_params()
  
      budget_accountant = pipeline_dp.NaiveBudgetAccountant(
          total_epsilon=1, total_delta=1e-10
      )
  
      data_extractors = pipeline_dp.DataExtractors(
          privacy_id_extractor=lambda x: x,
          partition_extractor=lambda x: f"pk{x}",
          value_extractor=lambda x: None,
      )
  
      engine = utility_analysis_engine.UtilityAnalysisEngine(
          budget_accountant=budget_accountant,
          backend=pipeline_dp.LocalBackend(),
      )
  
      options = analysis.UtilityAnalysisOptions(
          epsilon=1,
          delta=0,
          aggregate_params=aggregator_params,
          partitions_sampling_prob=0.25,
      )
      engine.analyze(
          col=[1, 2, 3],
          options=options,
          data_extractors=data_extractors,
      )
      mock_sampler_init.assert_called_once_with(0.25)
  
file_path: pipelinedp/analysis/tests/utility_analysis_engine_test.py
imports: from absl.testing import absltest
  from absl.testing import parameterized
  from unittest.mock import patch
  import copy
  import pipeline_dp
  from pipeline_dp import budget_accounting
  from analysis import utility_analysis_engine
  from analysis import metrics
  import analysis
label_desc: Use image node_id 9 for calling the UtilityAnalysisEngineTest obj's underlying member method code with example usage: obj.test_partition_sampling(mock_sampler_init) without return types