code: def create_run(
      ctx: Context,
      engine: str,
      pipeline_name: str,
      endpoint: str,
      iap_client_id: str,
      namespace: str,
      project: str,
      region: str,
      runtime_parameter: Iterable[str],
  ) -> None:
      """Command definition to create a pipeline run."""
      click.echo("Creating a run for pipeline: " + pipeline_name)
      ctx.flags_dict[labels.ENGINE_FLAG] = engine
      ctx.flags_dict[labels.PIPELINE_NAME] = pipeline_name
      ctx.flags_dict[labels.ENDPOINT] = endpoint
      ctx.flags_dict[labels.IAP_CLIENT_ID] = iap_client_id
      ctx.flags_dict[labels.NAMESPACE] = namespace
      ctx.flags_dict[labels.GCP_PROJECT_ID] = project
      ctx.flags_dict[labels.GCP_REGION] = region
      ctx.flags_dict[
          labels.RUNTIME_PARAMETER
      ] = _parse_runtime_parameters(runtime_parameter)
  
      handler = handler_factory.create_handler(ctx.flags_dict)
      if (
          ctx.flags_dict[labels.ENGINE_FLAG]
          not in (
              labels.KUBEFLOW_ENGINE,
              labels.AIRFLOW_ENGINE,
              labels.VERTEX_ENGINE,
          )
      ) and runtime_parameter:
          raise NotImplementedError(
              "Currently runtime parameter is only supported in kubeflow, vertex, "
              "and airflow."
          )
      handler.create_run()
  
file_path: tfx/tfx/tools/cli/commands/run.py
imports: from typing import Iterable, Dict
  import click
  from tfx.tools.cli import labels
  from tfx.tools.cli.cli_context import Context
  from tfx.tools.cli.cli_context import pass_context
  from tfx.tools.cli.handler import handler_factory
label_desc: Use image node_id 2 for calling a global function with example usage: create_run(ctx, engine, pipeline_name, endpoint, iap_client_id, namespace, project, region, runtime_parameter) without return types