code: def _get_test_output_dir():
      return "gs://{}/test_output".format(_BUCKET_NAME)
  
imports: import os
  from tfx.orchestration import pipeline
  from tfx.orchestration.kubeflow import kubeflow_dag_runner
  from tfx.tools.cli.e2e import test_utils
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 1 for calling a global function with example usage: _get_test_output_dir() and returns: str