code: def _get_config_value(
      config_value: kubeflow_pb2.ConfigValue,
  ) -> Optional[str]:
      value_from = config_value.WhichOneof("value_from")
  
      if value_from is None:
          raise ValueError(
              "No value set in config value: {}".format(config_value)
          )
  
      if value_from == "value":
          return config_value.value
  
      return os.getenv(config_value.environment_variable)
  
imports: import argparse
  import copy
  import json
  import logging
  import os
  import sys
  import textwrap
  from typing import cast, Dict, List, Mapping, MutableMapping, Optional, Sequence, Tuple, Union
  from tfx import types
  from tfx.dsl.compiler import constants
  from tfx.orchestration import metadata
  from tfx.orchestration.kubeflow.proto import kubeflow_pb2
  from tfx.orchestration.local import runner_utils
  from tfx.orchestration.portable import data_types
  from tfx.orchestration.portable import execution_publish_utils
  from tfx.orchestration.portable import kubernetes_executor_operator
  from tfx.orchestration.portable import launcher
  from tfx.orchestration.portable import runtime_parameter_utils
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.types import artifact
  from tfx.types import channel
  from tfx.types import standard_artifacts
  from tfx.utils import telemetry_utils
  from google.protobuf import json_format
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 2 for calling a global function with example usage: _get_config_value(config_value) and returns: os, config_value