class_docstr: Helper methods for Beam Handler.
class_docstr_tok: ["Helper","methods","for","Beam","Handler","."]
docstr: Runs a pipeline in Beam.
docstr_tok: ["Runs","a","pipeline","in","Beam","."]
code: def create_run(self) -> None:
      """Runs a pipeline in Beam."""
      pipeline_name = self.flags_dict[labels.PIPELINE_NAME]
  
      # Check if pipeline exists.
      self._check_pipeline_existence(pipeline_name)
  
      with open(self._get_pipeline_args_path(pipeline_name), "r") as f:
          pipeline_args = json.load(f)
  
      # Run pipeline dsl.
      self._subprocess_call(
          [sys.executable, str(pipeline_args[labels.PIPELINE_DSL_PATH])]
      )
  
imports: import json
  import sys
  from typing import Any, Dict
  import click
  from tfx.dsl.io import fileio
  from tfx.tools.cli import labels
  from tfx.tools.cli.handler import base_handler
  from tfx.tools.cli.handler import beam_dag_runner_patcher
  from tfx.tools.cli.handler import dag_runner_patcher
  from tfx.utils import io_utils
label_desc: Use image node_id 7 for calling the BeamHandler obj's underlying member method code with example usage: obj.create_run() without return types