code: def testPipelineCreateUnsupportedEngine(self):
      pipeline_path = os.path.join(
          self.chicago_taxi_pipeline_dir, "test_pipeline_beam_1.py"
      )
      result = self.runner.invoke(
          cli_group,
          [
              "pipeline",
              "create",
              "--engine",
              "flink",
              "--pipeline_path",
              pipeline_path,
          ],
      )
      self.assertIn("CLI", result.output)
      self.assertIn("Creating pipeline", result.output)
      self.assertIn(
          "Engine flink is not supported.", str(result.exception)
      )
  
file_path: tfx/tfx/tools/cli/e2e/cli_common_e2e_test.py
imports: import codecs
  import locale
  import os
  from click import testing
  import tensorflow
  from tfx.tools.cli.cli_main import cli_group
label_desc: Use image node_id 2 for calling the CliCommonEndToEndTest obj's underlying member method code with example usage: obj.testPipelineCreateUnsupportedEngine() without return types