code: def __init__(
      self,
      pipeline_node: pipeline_pb2.PipelineNode,
      mlmd_connection_config: metadata.ConnectionConfigType,
      pipeline_info: pipeline_pb2.PipelineInfo,
      pipeline_runtime_spec: pipeline_pb2.PipelineRuntimeSpec,
      executor_spec: Optional[message.Message],
      custom_driver_spec: Optional[message.Message],
      deployment_config: Optional[message.Message],
      pipeline: Optional[pipeline_pb2.Pipeline],
  ):
      super().__init__(
          pipeline_node,
          mlmd_connection_config,
          pipeline_info,
          pipeline_runtime_spec,
          executor_spec,
          custom_driver_spec,
          deployment_config,
          pipeline,
      )
      _component_executors[self._node_id] = executor_spec
      _component_drivers[self._node_id] = custom_driver_spec
      _component_platform_configs[
          self._node_id
      ] = self._extract_platform_config(
          self._deployment_config, self._node_id
      )
      pipeline_run = None
      for context in pipeline_node.contexts.contexts:
          if (
              context.type.name
              == constants.PIPELINE_RUN_CONTEXT_TYPE_NAME
          ):
              pipeline_run = context.name.field_value.string_value
      _component_to_pipeline_run[self._node_id] = pipeline_run
  
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 to create a new _FakeComponentAsDoFn object from inherited base classes: beam_dag_runner with example: obj = _FakeComponentAsDoFn(pipeline_node, mlmd_connection_config, pipeline_info, pipeline_runtime_spec, executor_spec, custom_driver_spec, deployment_config, pipeline)