code: def setUp(self):
      super().setUp()
      # Setup pipelines
      self._pipeline = pipeline_pb2.Pipeline()
      self.load_proto_from_text(
          os.path.join(
              os.path.dirname(__file__),
              "testdata",
              "pipeline_for_beam_dag_runner_test.pbtxt",
          ),
          self._pipeline,
      )
      _executed_components.clear()
      _component_executors.clear()
      _component_drivers.clear()
      _component_platform_configs.clear()
      _component_to_pipeline_run.clear()
  
imports: import os
  from typing import Optional
  from unittest import mock
  import tensorflow
  from tfx.dsl.compiler import constants
  from tfx.orchestration import metadata
  from tfx.orchestration.beam import beam_dag_runner
  from tfx.orchestration.beam.legacy import beam_dag_runner
  from tfx.orchestration.config import pipeline_config
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.proto.orchestration import local_deployment_config_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.proto.orchestration import platform_config_pb2
  from tfx.utils import test_case_utils
  from google.protobuf import message
  from google.protobuf import text_format
label_desc: Use image node_id 1 for calling the BeamDagRunnerTest obj's underlying member method code with example usage: obj.setUp() without return types