code: def _run_pipeline_get_metrics(self):
      pipelines = []
  
      def _create_pipeline_wrapper(*_):
          result = self._makeTestPipeline()
          pipelines.append(result)
          return result
  
      with tft_unit.mock.patch.object(
          executor.Executor,
          "_make_beam_pipeline",
          autospec=True,
          side_effect=_create_pipeline_wrapper,
      ):
          transform_executor = executor.Executor()
          transform_executor.Do(
              self._input_dict, self._output_dict, self._exec_properties
          )
      assert len(pipelines) == 1
      return pipelines[0].metrics
  
imports: import copy
  import json
  import os
  import re
  import tempfile
  from unittest import mock
  from absl.testing import parameterized
  import apache_beam
  import tensorflow
  import tensorflow_data_validation
  import tensorflow_transform
  from tensorflow_transform.beam import tft_unit
  from tfx import types
  from tfx.components.testdata.module_file import transform_module
  from tfx.components.transform import executor
  from tfx.dsl.io import fileio
  from tfx.proto import example_gen_pb2
  from tfx.proto import transform_pb2
  from tfx.types import artifact_utils
  from tfx.types import standard_artifacts
  from tfx.types import standard_component_specs
  from tfx.utils import io_utils
  from tfx.utils import name_utils
  from tfx.utils import proto_utils
label_desc: Use image node_id 9 for calling the ExecutorTest obj's underlying member method code with example usage: obj._run_pipeline_get_metrics() and returns: pipelines, result