code: def __init__(self, *args, **kwargs):
      super().__init__(*args, **kwargs)
      self.messages_to_fail = retryable_message_types
      self.messages_to_delay = default_messages_to_delay
  
file_path: pytorch/torch/testing/_internal/distributed/rpc/faulty_rpc_agent_test_fixture.py
imports: import torch.distributed.rpc
  import torch.distributed.rpc._testing
  from torch.testing._internal.distributed.rpc.rpc_agent_test_fixture import RpcAgentTestFixture
label_desc: Use image node_id 1 to create a new FaultyRpcAgentTestFixture object from inherited base classes: RpcAgentTestFixture with example: obj = FaultyRpcAgentTestFixture()