docstr: Gets the Argo workflow name using pipeline name.
docstr_tok: ["Gets","the","Argo","workflow","name","using","pipeline","name","."]
code: def _get_workflow_name(self, pipeline_name: str) -> str:
      """Gets the Argo workflow name using pipeline name."""
      get_workflow_name_command = (
          'argo --namespace %s list | grep -o "%s[^ ]*"'
          % (self._KFP_NAMESPACE, pipeline_name)
      )
      # Need to explicitly decode because the test fixture is running on
      # Python 3.5. Also need to remove the new line at the end of the string.
      return subprocess.check_output(
          get_workflow_name_command, shell=True
      ).decode("utf-8")[:-1]
  
imports: import datetime
  import os
  import subprocess
  from absl import logging
  import kfp
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.examples.penguin import penguin_kubeflow_gcp
  from tfx.orchestration import data_types
  from tfx.orchestration import pipeline
  from tfx.orchestration import test_utils
  from tfx.orchestration.kubeflow import kubeflow_dag_runner
  from tfx.orchestration.kubeflow import test_utils
label_desc: Use image node_id 2 for calling the KubeflowGcpPerfTest obj's underlying member method code with example usage: obj._get_workflow_name(pipeline_name) and returns: subprocess