code: def init_rpc():
      os.environ["MASTER_PORT"] = "10639"
      init_method = f"tcp://{os.environ['MASTER_ADDR']}:{os.environ['MASTER_PORT']}"
      rpc.init_rpc(
          f"Test{torch.distributed.get_rank()}",
          rank=torch.distributed.get_rank(),
          world_size=torch.distributed.get_world_size(),
          backend=rpc.BackendType.TENSORPIPE,
          rpc_backend_options=rpc.TensorPipeRpcBackendOptions(
              init_method=init_method
          ),
      )
  
file_path: fairscale/tests/nn/pipe_process/test_rpc.py
imports: import copy
  import os
  import pytest
  import torch
  from torch import nn
  from torch.distributed import rpc
  from fairscale.fair_dev.testing.testing import get_worker_map, torch_spawn
  from fairscale.internal import torch_version
  from fairscale.nn.model_parallel.initialize import get_pipeline_parallel_group
  from fairscale.nn.pipe import PipeRPCWrapper
label_desc: Use image node_id 1 for calling a global function with example usage: init_rpc() without return types