+ j&ZaRtT0t^RIt^RIt^RIt^RIt^RIHt^RIHt^RI H t ^RI t ^RI H tR.t]P !]4t^s]P(!4tRRlt]!4'd)] P.P14'g ]!R4h]!4'Ed]!] P.P6R 4t^RIt^RIH uHt ^R I!H"t"^R I#H$t$H%t%H&t&H't'H(t(H)t)H*t*H+t+H,t,H-t-H.t.H/t/H0t0H1t1H2t2H3t3H4t4H5t5H6t6H7t7H8t8H9t9H:t:H;t;Ht>H?t?H@t@HAtA]'d ^R I#HBtBHCtCHDtD^R IEHFtFHGtGHHtH^RIF5^RIGHItI^RIJHKtK^RILHMtM]^k].RO, t]]FP,]GP,tRRltNRtO]IPRRRRR3RltQ]FPR4tSR#R#)N) Generator) timedelta)urlparse is_availablec$V^8dQhR\/#)return)bool)formats"_/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/distributed/rpc/__init__.py __annotate__r s**d*c6\\PR4#) _rpc_init)hasattrtorch_Crr rrs 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_profilec X\PPR4Ve,\V\P 4'g \ R4hVe"\V\4'g \ R4hVfVe|\ F6p\V\\P!V444'gK4TpM \ RV 24hV\ P8wd\PRRV/4Vf\ PpVf\P!V4pV'g\P!WB4pM5\P!VP W#R7s\%\"4wppVP'\)VP*R 74\,;_uu_4\P.!\1R \2 24V4p\2^, sRRR4\4P6!V4\9V4\;WWW44R# +'giL@;i) 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_)rr_log_api_usage_once isinstancer8r; TypeErrorr3typeconstruct_rpc_backend_options TENSORPIPEloggerwarningdist_create_store_from_options rendezvous init_methodrendezvous_iteratornext set_timeoutr rpc_timeout_init_counter_lock PrefixStorestr _init_counter dist_autograd_initr+_init_rpc_backend)namer?r@rArpc_backend_optionscandidate_backendstore_s&&&&& r init_rpcr`]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 ,5H H) c FV\PV\PV\V\ P V\ P \R43V\/pVP4F3wrx\Wx4'dK\RV RV R\V4 24h R#)Nz Argument z must be of type z but got type ) r8r;rLrrVnumbersIntegralrGr3itemsrE RuntimeError) r?r^r[r@rAr\ type_mappingargarg_types &&&&&& r _validate_rpc_argsris %11 4:: # '"" ))4:6 !2 *//1MCc,,"u$5hZ~dSVi[Y2rc \WW#WE4\4'd \R4h\P!VVVVVVR7p\ P !V4R#)zRPC is already initialized)r^r[r@rAr\N)rir'rer8 init_backendr7_init_rpc_states)r?r^r[r@rAr\ rpc_agents&&&&&& r rZrZsY 74zW $ & &;< <%11 ! 3   Y'rc\4pVP\P!4P 44VP\ P !44V#)N)r)updater7r get_debug_inforX_get_debug_info)infos r rqrqsB+- C..0??AB M1134 rcV^8dQh/^\9d.\\\\\3,RR3,;R&#)rNrP)__conditional_annotations__rtuplerint)r s"r r r s2jGF5S#94#EFFkr)r`r;r<)NrwNN)Urtloggingos threadingwarningscollections.abcrdatetimer urllib.parserrtorch.distributed distributedrL__all__ getLogger__name__rJrWLockrTrrrrer_distributed_rpc_is_tensorpipe_availablerbtorch.distributed.autogradautogradrXtorch._C._distributed_c10drtorch._C._distributed_rpcrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5rr6r7r8r9r;optionsr<server_process_global_profilerr=r`rirIrZ_require_initializedrqr )rts@r rsq %!      8 $ ^^%*>>%((,,.. C DD>>& !!#E 660B   32-4NF IIG #&6&>&>>GuWn"&&   (2 }r