docstr: Deletes output produced by the named pipeline.
  
  Args:
    pipeline_name: The name of the pipeline.
code: def _delete_pipeline_output(self, pipeline_name: str) -> None:
      """Deletes output produced by the named pipeline.
  
      Args:
        pipeline_name: The name of the pipeline.
      """
      if ("KFP_E2E_GCP_PROJECT_ID" not in os.environ) or (
          "KFP_E2E_BUCKET_NAME" not in os.environ
      ):
          return
      client = storage.Client(
          project=os.environ["KFP_E2E_GCP_PROJECT_ID"]
      )
      bucket = client.get_bucket(os.environ["KFP_E2E_BUCKET_NAME"])
      prefix = "test_output/{}".format(pipeline_name)
      absl.logging.info(
          "Deleting output under GCS bucket prefix: {}".format(prefix)
      )
      blobs = list(bucket.list_blobs(prefix=prefix))
      bucket.delete_blobs(blobs)
  
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 9 for calling the CliKubeflowEndToEndTest obj's underlying member method code with example usage: obj._delete_pipeline_output(pipeline_name) without return types