code: def remote_add(t1, t2, dst: str):  # noqa: E999
      return rpc_async(dst, local_add, (t1, t2)).wait()
  
file_path: pytorch/torch/testing/_internal/distributed/rpc/jit/dist_autograd_test.py
imports: from typing import Dict, Tuple
  import torch
  import torch.distributed.autograd
  import torch.distributed.rpc
  from torch import Tensor
  from torch.distributed.rpc import rpc_async
  from torch.testing import FileCheck
  from torch.testing._internal.dist_utils import dist_init, worker_name
  from torch.testing._internal.distributed.rpc.rpc_agent_test_fixture import RpcAgentTestFixture
label_desc: Use image node_id 2 for calling a global function with example usage: remote_add(t1, t2, dst) and returns: rpc_async