code: def _local_invoke_async_execution(rref, func_name, args, kwargs):
      return getattr(rref.local_value(), func_name)(*args, **kwargs)
  
file_path: pytorch/torch/distributed/rpc/rref_proxy.py
imports: from functools import partial
  from .None import functions
  from .None import rpc_async
  import torch
  from .constants import UNSET_RPC_TIMEOUT
  from torch.futures import Future
label_desc: Use image node_id 2 for calling a global function with example usage: _local_invoke_async_execution(rref, func_name, args, kwargs) and returns: getattr