code: def _get_csv_input_location():
      return os.path.join(_TESTDATA_ROOT, "external", "csv")
  
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 2 for calling a global function with example usage: _get_csv_input_location() and returns: os