code: def testDockerComponentLauncherInBeam(self):
      beam_dag_runner.BeamDagRunner().run(
          _create_pipeline(
              pipeline_name=self._pipeline_name,
              pipeline_root=self._pipeline_root,
              metadata_path=self._metadata_path,
              name="docker_e2e_test_in_beam",
          )
      )
  
      metadata_config = metadata.sqlite_metadata_connection_config(
          self._metadata_path
      )
      with metadata.Metadata(metadata_config) as m:
          self.assertEqual(1, len(m.store.get_executions()))
  
file_path: tfx/tfx/orchestration/portable/docker_executor_operator_e2e_test.py
imports: import os
  import tensorflow
  from tfx.dsl.component.experimental import executor_specs
  from tfx.dsl.components.base import base_component
  from tfx.orchestration import metadata
  from tfx.orchestration import pipeline
  from tfx.orchestration.beam import beam_dag_runner
  from tfx.types import component_spec
label_desc: Use image node_id 2 for calling the DockerComponentLauncherE2eTest obj's underlying member method code with example usage: obj.testDockerComponentLauncherInBeam() without return types