code: def _recv_object(
      src: int, dst: int, group: ProcessGroup, **kwargs
  ) -> Any:
      """recv anything from src
  
      Args:
          src (int): source rank of data. local rank will receive data from src rank.
  
      Returns:
          Any: Object received from src.
      """
      return _communicate(
          None, send_dst=None, recv_src=src, recv_group=group, **kwargs
      )
  
imports: import io
  import pickle
  import re
  from collections import namedtuple
  from typing import Any, Callable, List, Optional, Tuple, Union
  import torch
  import torch.distributed
  from packaging.version import Version
  from torch.distributed import ProcessGroup
  from torch.distributed import distributed_c10d
  from torch.utils._pytree import tree_flatten, tree_unflatten
  from .stage_manager import PipelineStageManager
label_desc: Use image node_id 12 for calling a global function with example usage: _recv_object(src, dst, group) and returns: _communicate