code: def testRecordLatestBeamPipeline(
      self, mock_get_latest_executions, mock_metadata, mock_config
  ):
      # Tests recording Beam pipeline outputs for the latest execution.
      with mock.patch.object(
          pipeline_recorder_utils, "_get_paths", return_value=self.paths
      ) as mock_get_paths:
          pipeline_recorder_utils.record_pipeline(
              output_dir=self._base_dir,
              metadata_db_uri=self.metadata_db_uri,
              pipeline_name=self.pipeline_name,
          )
  
          mock_config.assert_called_with(self.metadata_db_uri)
          mock_metadata.assert_called()
          mock_get_paths.assert_called()
          mock_get_latest_executions.assert_called()
  
          # Verifying that test.txt has been copied from src_uri to dest_uri
          files = fileio.listdir(self.dest_uri)
          self.assertLen(files, 1)
          self.assertEqual(
              io_utils.read_string_file(
                  os.path.join(self.dest_uri, files[0])
              ),
              self.content,
          )
  
file_path: tfx/tfx/experimental/pipeline_testing/pipeline_recorder_utils_test.py
imports: import os
  from unittest import mock
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.experimental.pipeline_testing import pipeline_recorder_utils
  from tfx.utils import io_utils
label_desc: Use image node_id 4 for calling the PipelineRecorderUtilsTest obj's underlying member method code with example usage: obj.testRecordLatestBeamPipeline(mock_get_latest_executions, mock_metadata, mock_config) without return types