code: def get_kubeflow_value(
      tfx_value: Union[int, float, str]
  ) -> Optional[pipeline_pb2.Value]:
      """Converts TFX/MLMD values into Kubeflow pipeline Value proto message."""
      if tfx_value is None:
          return None
  
      result = pipeline_pb2.Value()
      if isinstance(tfx_value, int):
          result.int_value = tfx_value
      elif isinstance(tfx_value, float):
          result.double_value = tfx_value
      elif isinstance(tfx_value, str):
          result.string_value = tfx_value
      else:
          raise TypeError(
              "Got unknown type of value: {}".format(tfx_value)
          )
  
      return result
  
imports: import itertools
  import json
  import os
  import re
  from typing import Any, Dict, List, Mapping, Optional, Type, Union
  from kfp.pipeline_spec import pipeline_spec_pb2
  from tfx import types
  from tfx.dsl.io import fileio
  from tfx.orchestration import data_types
  from tfx.orchestration.kubeflow.v2 import parameter_utils
  from tfx.proto.orchestration import placeholder_pb2
  from tfx.types import artifact
  from tfx.types import channel
  from tfx.types import standard_artifacts
  from tfx.types.experimental import simple_artifacts
  from tfx.utils import json_utils
  from tfx.utils import name_utils
  import yaml
  from google.protobuf import struct_pb2
  from google.protobuf import json_format
  from google.protobuf import message
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 9 for calling a global function with example usage: get_kubeflow_value(tfx_value) and returns: result, None