code: def _verify_anomalies(self, output_uri: str, expected_uri: str):
      self.assertTrue(
          executor_verifier_utils.compare_anomalies(
              output_uri, expected_uri
          )
      )
  
imports: import os
  from absl import logging
  import tensorflow
  from tfx.dsl.compiler import compiler
  from tfx.dsl.io import fileio
  from tfx.examples.chicago_taxi_pipeline import taxi_pipeline_local
  from tfx.experimental.pipeline_testing import executor_verifier_utils
  from tfx.experimental.pipeline_testing import pipeline_mock
  from tfx.experimental.pipeline_testing import pipeline_recorder_utils
  from tfx.orchestration import metadata
  from tfx.orchestration.beam.beam_dag_runner import BeamDagRunner
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 9 for calling the TaxiPipelineRegressionEndToEndTest obj's underlying member method code with example usage: obj._verify_anomalies(output_uri, expected_uri) without return types