/usr/local/lib64/python3.6/site-packages/torch/_C
NameSizeModeActions
_autograd.pyi27440644editdlrm
_cudnn.pyi3780644editdlrm
_distributed_autograd.pyi9080644editdlrm
_distributed_c10d.pyi93760644editdlrm
_distributed_rpc.pyi56300644editdlrm
_distributed_rpc_testing.pyi11360644editdlrm
_functions.pyi3450644editdlrm
_nn.pyi20500644editdlrm
_nvtx.pyi1500644editdlrm
_onnx.pyi6460644editdlrm
_VariableFunctions.pyi1410260644editdlrm
__init__.pyi1039060644editdlrm
Edit: /usr/local/lib64/python3.6/site-packages/torch/_C/_distributed_rpc_testing.pyi (1136B)
import torch from ._distributed_c10d import ProcessGroup, Store from ._distributed_rpc import ( _TensorPipeRpcBackendOptionsBase, TensorPipeAgent, WorkerInfo, ) from typing import List, Dict, overload from datetime import timedelta # This module is defined in torch/csrc/distributed/rpc/testing/init.cpp class FaultyTensorPipeRpcBackendOptions(_TensorPipeRpcBackendOptionsBase): def __init__( self, num_worker_threads: int, rpc_timeout: float, init_method: str, messages_to_fail: List[str], messages_to_delay: Dict[str, float], num_fail_sends: int, ): ... num_send_recv_threads: int messages_to_fail: List[str] messages_to_delay: Dict[str, float] num_fail_sends: int class FaultyTensorPipeAgent(TensorPipeAgent): def __init__( self, store: Store, name: str, rank: int, world_size: int, process_group: ProcessGroup, options: FaultyTensorPipeRpcBackendOptions, reverse_device_maps: Dict[str, Dict[torch.device, torch.device]], devices: List[torch.device], ): ...