def METHOD_NAME(self):
    if self.rank != 0:
        return
    dst_rank = (self.rank + 1) % self.world_size
    dst_worker = f"worker{dst_rank}"
    rref = rpc.remote(
        dst_worker, torch.add, args=(torch.tensor(1), torch.tensor(1))
    )
    expected_error = self.get_timeout_error_regex()
    with self.assertRaisesRegex(RuntimeError, expected_error):
        rref_to_here_with_timeout(rref, 0.01)
    rref_to_here_with_timeout(rref, 100)