docstr: Gets the workflow log for all the pods using pipeline name.
docstr_tok: ["Gets","the","workflow","log","for","all","the","pods","using","pipeline","name","."]
code: def _get_workflow_log(self, pipeline_name: str) -> str:
      """Gets the workflow log for all the pods using pipeline name."""
      get_workflow_log_command = [
          "argo",
          "--namespace",
          self._KFP_NAMESPACE,
          "logs",
          "-w",
          self._get_workflow_name(pipeline_name),
      ]
      # Need to explicitly decode because the test fixture is running on
      # Python 3.5.
      return subprocess.check_output(get_workflow_log_command).decode(
          "utf-8"
      )
  
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 3 for calling the KubeflowGcpPerfTest obj's underlying member method code with example usage: obj._get_workflow_log(pipeline_name) and returns: subprocess