recv#

ray.util.collective.collective.recv(tensor: Any, src_rank: int, group_name: str = 'default')[source]#

Receive a tensor from a remote process synchronously.

Parameters:
  • tensor (Any) – the received tensor.

  • src_rank (int) – the rank of the source process.

  • group_name (str) – the name of the collective group.