code: def _get_live_output_artifacts_for_node(
      mlmd_handle: metadata.Metadata, node_uid: task_lib.NodeUid
  ) -> Mapping[str, Sequence[metadata_store_pb2.Artifact]]:
      """Gets all the live output artifacts keyed by output key for `node_uid`."""
      live_output_artifacts_of_node_by_output_key = (
          store_ext.get_live_output_artifacts_of_node_by_output_key(
              mlmd_handle.store,
              pipeline_id=node_uid.pipeline_uid.pipeline_id,
              node_id=node_uid.node_id,
          )
      )
      return {
          output_key: list(
              itertools.chain.from_iterable(nested_artifact_list)
          )
          for output_key, nested_artifact_list in live_output_artifacts_of_node_by_output_key.items()
      }
  
imports: import collections
  import itertools
  from typing import Mapping, Optional, Sequence
  from absl import logging
  from tfx import types
  from tfx.dsl.io import fileio
  from tfx.orchestration import data_types_utils
  from tfx.orchestration import metadata
  from tfx.orchestration import node_proto_view
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.portable.mlmd import event_lib
  from tfx.orchestration.portable.mlmd import execution_lib
  from tfx.orchestration.portable.mlmd import store_ext
  from tfx.proto.orchestration import garbage_collection_policy_pb2
  from tfx.orchestration.experimental.core import garbage_collection_extensions
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 1 for calling a global function with example usage: _get_live_output_artifacts_for_node(mlmd_handle, node_uid) and returns: unknown