code: def _valid_run_and_check(self, pipeline_name):
      # Wait to fill up the DagBag.
      response = ""
      while pipeline_name not in response:
          response = str(
              subprocess.check_output(["airflow", "dags", "list"])
          )
  
      self._reload_airflow_dags()
  
      with airflow_test_utils.AirflowScheduler():
          result = self.runner.invoke(
              cli_group,
              [
                  "run",
                  "create",
                  "--engine",
                  "airflow",
                  "--pipeline_name",
                  pipeline_name,
              ],
          )
  
      self.assertIn(
          "Creating a run for pipeline: {}".format(pipeline_name),
          result.output,
      )
      self.assertNotIn(
          'Pipeline "{}" does not exist.'.format(pipeline_name),
          result.output,
      )
      self.assertIn(
          "Run created for pipeline: {}".format(pipeline_name),
          result.output,
      )
  
imports: import codecs
  import locale
  import os
  import subprocess
  import sys
  import time
  import absl
  from click import testing
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.orchestration.airflow import test_utils
  from tfx.tools.cli import labels
  from tfx.tools.cli import pip_utils
  from tfx.tools.cli.cli_main import cli_group
  from tfx.tools.cli.e2e import test_utils
  from tfx.utils import io_utils
  from tfx.utils import retry
  from tfx.utils import test_case_utils
label_desc: Use image node_id 14 for calling the CliAirflowEndToEndTest obj's underlying member method code with example usage: obj._valid_run_and_check(pipeline_name) without return types