Ei&P%SSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSK r SSK J r S/r\R"\5rSq\R&"5rS\4Sjr\"5(a'\ R.R15(d\"S5e\"5(Ga \"\ R.R6S 5rSSKrSSKJ s Jr SS K!J"r" SS K#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r;Jr>J?r?J@r@JArA \(a SS K#JBrBJCrCJDrD S SKEJFrFJGrGJHrH S SKF7 S SKGJIrI S SKJJKrK S SKLJMrM \\N\"\O\O4SS4\PS'\/SQ- r\\FR-\GR-rSSjrQSrR\IRSSSSS4SjrT\FRS5rVgg)N) Generator) timedelta)urlparse is_availablereturnc6[[RS5$)N _rpc_init)hasattrtorch_C[/home/mande/repo/quber/.venv/lib/python3.13/site-packages/torch/distributed/rpc/__init__.pyrrs 588[ ))rz*Failed to initialize torch.distributed.rpc _TensorPipeRpcBackendOptionsBase)Store)_cleanup_python_rpc_handler_DEFAULT_INIT_METHOD_DEFAULT_RPC_TIMEOUT_SEC)_delete_all_user_and_unforked_owner_rrefs_destroy_rref_context_disable_jit_rref_pickle'_disable_server_process_global_profiler_enable_jit_rref_pickle&_enable_server_process_global_profiler_get_current_rpc_agent_invoke_remote_builtin_invoke_remote_python_udf_invoke_remote_torchscript_invoke_rpc_builtin_invoke_rpc_python_udf_invoke_rpc_torchscript_is_current_rpc_agent_set_reset_current_rpc_agent_rref_context_get_debug_info_set_and_start_rpc_agent_set_profiler_node_id_set_rpc_timeout_UNSET_RPC_TIMEOUTenable_gil_profilingget_rpc_timeoutPyRRefRemoteProfilerManagerRpcAgentRpcBackendOptions WorkerInfo)_DEFAULT_NUM_WORKER_THREADSrTensorPipeAgent)apibackend_registry functions)*) BackendType)TensorPipeRpcBackendOptions)_server_process_global_profilerendezvous_iterator)init_rpcr7r8c [RRS5 Ub*[U[R 5(d [ S5eUb [U[5(d [ S5eUc|Uby[ H5n[U[[R"U555(dM3Un O [ SU35eU[ R:wa[RSSU05 Uc[ RnUc[R"U5nU(d[R"XB5nO2[R"UR X#S9q[%["5un nUR'[)UR*S 95 [, [R."[1S [235U5n[2S - qSSS5 [4R6"U5 [9U5 [;XXX45 g!,(df  N==f) a Initializes RPC primitives such as the local RPC agent and distributed autograd, which immediately makes the current process ready to send and receive RPCs. Args: name (str): a globally unique name of this node. (e.g., ``Trainer3``, ``ParameterServer2``, ``Master``, ``Worker1``) Name can only contain number, alphabet, underscore, colon, and/or dash, and must be shorter than 128 characters. backend (BackendType, optional): The type of RPC backend implementation. Supported values is ``BackendType.TENSORPIPE`` (the default). See :ref:`rpc-backends` for more information. rank (int): a globally unique id/rank of this node. world_size (int): The number of workers in the group. rpc_backend_options (RpcBackendOptions, optional): The options passed to the RpcAgent constructor. It must be an agent-specific subclass of :class:`~torch.distributed.rpc.RpcBackendOptions` and contains agent-specific initialization configurations. By default, for all agents, it sets the default timeout to 60 seconds and performs the rendezvous with an underlying process group initialized using ``init_method = "env://"``, meaning that environment variables ``MASTER_ADDR`` and ``MASTER_PORT`` need to be set properly. See :ref:`rpc-backends` for more information and find which options are available. ztorch.distributed.init_rpcNz0Argument backend must be a member of BackendTypezEArgument rpc_backend_options must be an instance of RpcBackendOptionsz$Could not infer backend for options zRPC was initialized with no explicit backend but with options corresponding to %(backend)s, hence that backend will be used instead of the default BackendType.TENSORPIPE. To silence this warning pass `backend=%(backend)s` explicitly.backend)rank world_size)seconds rpc_prefix_r2)r r _log_api_usage_once isinstancer4r7 TypeErrorr.typeconstruct_rpc_backend_options TENSORPIPEloggerwarningdist_create_store_from_options rendezvous init_methodr:next set_timeoutr rpc_timeout_init_counter_lock PrefixStorestr _init_counter dist_autograd_initr&_init_rpc_backend)namer>r?r@rpc_backend_optionscandidate_backendstore_s rr;r;\sF $$%AB  z %11( ( NO O  *: !24 4 W  ?2>%0!'(FF-0G&1 :;N:OP+000E(  ?!,,G  &"2"P"P#  334GNE #'//#//d# 23KE1a ),?,K,KLM $$S;}o)F%GOE Q M  D!d#'$jV s 1G;; H c BU[RU[RU[U[ R U[ R [S54U[0nUR5H2upx[Xx5(aM[SUSUS[U535e g)Nz Argument z must be of type z but got type ) r4r7rKrrTnumbersIntegralrFr.itemsrD RuntimeError) r>r\rYr?r@rZ type_mappingargarg_types r_validate_rpc_argsrfs %11 4:: # '"" ))4:6 !2 *//1MCc,,"u$5hZ~dSVi[Y2rc [XX#XE5 [5(a [S5e[R"UUUUUUS9n[ R "U5 g)NzRPC is already initialized)r\rYr?r@rZ)rfr"rbr4 init_backendr3_init_rpc_states)r>r\rYr?r@rZ rpc_agents rrXrXsY 74zW $ & &;< <%11 ! 3   Y'rc[5nUR[R"5R 55 UR[ R "55 U$)N)r$updater3rget_debug_inforV_get_debug_info)infos rrnrnsB+- C..0??AB M1134 r)Nr<NN)Wloggingos threadingwarningscollections.abcrdatetimer urllib.parserr torch.distributed distributedrK__all__ getLogger__name__rIrULockrRboolrr r rbr _distributed_rpc_is_tensorpipe_availabler_torch.distributed.autogradautogradrVtorch._C._distributed_c10drtorch._C._distributed_rpcrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0rr1r3r4r5r7optionsr8server_process_global_profilerr9tupleint__annotations__r;rfrHrX_require_initializedrnr rrrs %!      8 $ ^^%*d*>>%((,,.. C DD>>& !!#E 660B   32-4N"5S#94#EFF IIG #&6&>&>>G  uWn"&&   (2 {r