code: def get_node_executions(
      store: mlmd.MetadataStore,
      *,
      pipeline_id: str,
      node_id: str,
      pipeline_run_id: Optional[str] = None,
      order_by: mlmd.OrderByField = mlmd.OrderByField.ID,
      is_asc: bool = True,
      execution_states: Optional[
          Sequence["mlmd.proto.Execution.State"]
      ] = None,
      min_last_update_time_since_epoch: Optional[int] = None,
  ) -> Sequence[mlmd.proto.Execution]:
      """Gets all node executions.
  
      Args:
        store: A MetadataStore object.
        pipeline_id: The pipeline ID.
        node_id: The node ID.
        pipeline_run_id: The pipeline run ID that the node belongs to. Only
          executions from the specified pipeline run are returned if specified.
        order_by: The field of execution to order results by.
        is_asc: If True, the results will be returned in the ascending order. If
          False, the result will be returned in the descending order.
        execution_states: The MLMD execution state(s) to pull LIVE artifacts from.
          If not specified or is empty, will consider all MLMD execution states.
        min_last_update_time_since_epoch: The minimum update time of MLMD executions
          in the format of milliseconds since the unix epoch. If not specified, will
          consider all MLMD executions.
  
      Returns:
        A list of executions of the given pipeline node.
      """
      node_context_name = compiler_utils.node_context_name(
          pipeline_id, node_id
      )
  
      node_executions_filter_queries = []
      node_executions_filter_queries.append(
          q.And(
              [
                  f'contexts_0.type = "{constants.NODE_CONTEXT_TYPE_NAME}"',
                  f'contexts_0.name = "{node_context_name}"',
              ]
          )
      )
      if pipeline_run_id:
          node_executions_filter_queries.append(
              q.And(
                  [
                      f'contexts_1.type = "{constants.PIPELINE_RUN_CONTEXT_TYPE_NAME}"',
                      f'contexts_1.name = "{pipeline_run_id}"',
                  ]
              )
          )
      if execution_states:
          states_str = ",".join(
              [
                  mlmd.proto.Execution.State.Name(state)
                  for state in execution_states
              ]
          )
          states_filter_query = f"last_known_state IN ({states_str})"
          node_executions_filter_queries.append(states_filter_query)
  
      if min_last_update_time_since_epoch:
          node_executions_filter_queries.append(
              f"last_update_time_since_epoch >= {min_last_update_time_since_epoch}"
          )
      return store.get_executions(
          list_options=mlmd.ListOptions(
              filter_query=str(q.And(node_executions_filter_queries)),
              order_by=order_by,
              is_asc=is_asc,
          )
      )
  
file_path: tfx/tfx/orchestration/portable/mlmd/store_ext.py
imports: import collections
  import itertools
  from typing import Callable, Mapping, Optional, Sequence, Union
  from tfx.dsl.compiler import compiler_utils
  from tfx.dsl.compiler import constants
  from tfx.orchestration.experimental.core import constants
  from tfx.orchestration.portable.mlmd import event_lib
  from tfx.orchestration.portable.mlmd import filter_query_builder
  import ml_metadata
label_desc: Use image node_id 4 for calling a global function with example usage: get_node_executions(store) and returns: store