code: def testPipelineCreateAutoDetectFail(self):
      if labels.AIRFLOW_PACKAGE_NAME not in self._pip_list:
          self.skipTest(
              "Airflow doesn't exist. Airflow needed to make auto detect fail."
          )
      with self.assertRaises(subprocess.CalledProcessError) as cm:
          test_utils.run_cli(
              [
                  "pipeline",
                  "create",
                  "--engine",
                  "auto",
                  "--pipeline_path",
                  self._pipeline_path,
                  "--endpoint",
                  self._endpoint,
              ]
          )
      self.assertIn(
          "Multiple orchestrators found. Choose one using --engine flag.",
          cm.exception.output,
      )
  
imports: import codecs
  import locale
  import os
  import subprocess
  import sys
  from typing import Optional
  import absl
  from google.cloud import storage
  import kfp
  import kfp_server_api
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.tools.cli import labels
  from tfx.tools.cli import pip_utils
  from tfx.tools.cli.e2e import test_utils
  from tfx.utils import retry
  from tfx.utils import test_case_utils
label_desc: Use image node_id 18 for calling the CliKubeflowEndToEndTest obj's underlying member method code with example usage: obj.testPipelineCreateAutoDetectFail() without return types