+ j*aR$t#0t^RIHtHt^RIt^RIt^RIt^RI H t H t ^RI H t ^RIHtHtHt^RIHt/s]^kRR .tR tR R ltR RltRRltR%RRlltRtRtRRltRRltRRltR&RRllt ]3RRllt!]3RR llt"]!R!]!4]!R"]"4]!R#]4R# ]dt]!R4]hRtAii;i)')urlparse urlunparsezEurllib cannot be found, urlparse from python2 is no longer supported.N)CallableIterator) timedelta) FileStoreStoreTCPStore)default_pg_timeoutregister_rendezvous_handler rendezvouscLV\9d\RV R24hV\V&R#)a Register a new rendezvous handler. Before we can run collective algorithms, participating processes need to find each other and exchange information to be able to communicate. We call this process rendezvous. The outcome of the rendezvous process is a triplet containing a shared key/value store, the rank of the process, and the total number of participating processes. If none of the bundled rendezvous methods apply to your execution environment you can opt to register your own rendezvous handler. Pick a unique name and use the URL scheme to identify it when calling the `rendezvous()` function. Args: scheme (str): URL scheme to identify your rendezvous handler. handler (function): Handler that is invoked when the `rendezvous()` function is called with a URL that uses the corresponding scheme. It must be a generator function that yields the triplet. zRendezvous handler for z:// already registeredN)_rendezvous_handlers RuntimeError)schemehandlers&&]/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/distributed/rendezvous.pyr r s.2%%4VH!_query_to_dict..<sP1OZZ__1OsN&)filterr )rr"s& r_query_to_dictr'9sLQekk#>N1OP PD QaP  sAcRV^8dQhR\\\3,R\/#)r query_dictr)rrbool)rs"rrr@s&PPtCH~P$Prc\PR8Xd4VPR\PPRR44R8H#VPR\PPRR44R8H#)win32 use_libuv USE_LIBUV01)sysplatformgetosenviron)r)s&r_get_use_libuv_from_query_dictr6@s[ ||w~~k2::>>+s+KLPSSS >>+rzz~~k3'G HC OOrcJV^8dQhR\R\R\R,/#)rurlrankworld_size_optNrint)rs"rrrIs%>>C>s>C$J>rc \V4pVfgR pVPR8XdS\\PP RV44p\\PP RV44pMTpVR 8wg VR 8wgVf\ VP4pRV9gRV9d\RV R24hVR 8wd\V4VR&VR 8wgVf\V4VR&TPRPVP4UUu.uF wrxV R V 2NK upp4 R 7p\V4pVP\9d\R VP R 24h\VP,!V3/VB#uuppi)NenvRANK WORLD_SIZEr9 world_sizez The url: z7 has node-specific arguments(rank, world_size) already.r%r)rzNo rendezvous handler for z://)rrr<r4r5r3r'rAssertionErrorr_replacejoinitemsrrr) r8r9r:kwargsresultrAr)kvs &&&, r_rendezvous_helperrKIso c]F ==E !rzz~~fd34DRZZ^^L*EFJ#  rzZ2%)?#FLL1 Z <:#= C5 WX  2:!$TJv   ~5'*:J| $XXj6F6F6HI6Hda!AaSz6HIJK!   }}007 cJKK  .s =f ==JsF c<V^8dQhR\R\R\/#)rr8r9rAr;)rs"rrrhs! ? ?C ?s ?S ?rc @\V\\34'g\R\ V4 RV 24h\V\ P 4'g\RV 24h\V\ P 4'g\RV 24h\WV3/VB#)z`url` must be a string. z: z`rank` must be an integer. z!`world_size` must be an integer. ) isinstancerbytesrtypenumbersIntegralrK)r8r9rArGs&&&,rr r hs cC< ( (5d3i[3%HII dG,, - -8?@@ j'"2"2 3 3>zlKLL c >v >>rcN\\VPVR44wppV#N)nextrK init_method)backend_optionsr9store_s&& r_create_store_from_optionsrZus')/*E*EtTRSKE1a Lrc&\RV,4#)z+Error initializing torch.distributed using ) ValueErrormsgs&r_rendezvous_errorr_zs CcI JJrc$V^8dQhR\/#)rr8r)rs"rrr~sNN#Nrc+4"Rp\V4pVPp\PR8Xdd^RIpVP VP,pVP PV4pV'd \PPV4pV'g V!R4h\VP4pRV9d V!R4hRV9d V!R4h\VR,4p\VR,4p \WI4p WV 3x\R4h5i) c&\RV,4#)zfile:// rendezvous: r_r]s&r_error(_file_rendezvous_handler.._errors !7#!=>>rr,Nz path missingr9rank parameter missingrAworld size parameter missingz3Unable to perform rerendezvous using file:// method)rpathr1r2urllib.requestnetlocrequest url2pathnamer4normpathr'rr<rr) r8rGrerHriurllib full_pathr)r9rArXs &, r_file_rendezvous_handlerrq~s?c]F ;;D ||wMMFKK/ ~~**95 77##D)D ^$$ -J Z-..:%344 z&! "DZ -.J d 'E  ## L MMsA3D6&DA;Dc$V^8dQhR\/#rrr*)rs"rrrsMMtMrcZ\PPRR4\R48H#)TORCHELASTIC_USE_AGENT_STORENT)r4r5r3rrr_torchelastic_use_agent_storerxs! ::>>8$ ?3t9 LLrc$V^8dQhR\/#rsrt)rs"rrrs  4 rc\4;'dV\PPR4V8H;'d,\PPR4\ V48H#)aWhether the elastic agent is the one serving a store at ``hostname:port``. ``TORCHELASTIC_USE_AGENT_STORE`` only promises a server at the agent's own ``MASTER_ADDR:MASTER_PORT``, which the agent exports alongside it. Honoring the flag for any other endpoint makes every rank a client of a store nobody hosts. ``TCPStore``'s C++ constructor applies the same address check before it forgives a failed server bind. MASTER_ADDR MASTER_PORT)rxr4r5r3r)hostnameports&&r_agent_store_servesrsQ &' 7 7 JJNN= )X 5 7 7 JJNN= )SY 6rc$V^8dQhR\/#rs)r )rs"rrrs- -  - rc ^Tu;8:dR8gM\RV R24h\W4'd\VVVRVR7#V^8Hp\VVVVVRVR7#)a  Smartly creates a c10d Store object on ``rank`` based on whether we need to reuse agent store. The TCPStore server is assumed to be hosted on ``hostname:port``. By default, the TCPStore server uses the asynchronous implementation ``LibUVStoreDaemon`` which utilizes libuv. If ``torchelastic_use_agent_store()`` is ``True`` *and* ``hostname:port`` is the agent's own ``MASTER_ADDR:MASTER_PORT``, then it is assumed that the agent leader (node rank 0) hosts the TCPStore server there. Hence ALL ranks will create and return a TCPStore client (e.g. ``start_daemon=False``). Otherwise rank 0 will host the TCPStore (with multi-tenancy) and it is assumed that rank 0's hostname and port are correctly passed via ``hostname`` and ``port``. All non-zero ranks will create and return a TCPStore client. z-port must have value from 0 to 65535 but was .F) host_namer~rA is_mastertimeoutT)rr~rArr multi_tenantr-i)r\rr )r}r~r9rArr- start_daemons&&&&&& r_create_c10d_storersz.  u HaPQQ8**!   qy !"  rc0V^8dQhR\R\/#rr8rrr)rs"rrrs NN N Nrc+"Rp\V4pVPf V!R4h\VP4pRV9d V!R4hRV9d V!R4h\ VR,4p\ VR,4p\ V4pVP f \R4h\VP VPWgW4p WV3x\R4h5i)c&\RV,4#)ztcp:// rendezvous: rdr]s&rre'_tcp_rendezvous_handler.._error !6!<==rzport number missingr9rgrArhzhostname cannot be Nonez3Unable to perform re-rendezvous using tcp:// method) rr~r'rr<r6r}rCrr) r8rrGrerHr)r9rAr-rXs &&, r_tcp_rendezvous_handlerrs>c]F {{*++ -J Z-..:%344 z&! "DZ -.J.z:I 677 d E  ## L MMsCCc0V^8dQhR\R\/#rr)rs"rrrs -N-N -N -Nrc+a a "Ro V 3Rlo RV 3Rllp\V4p\VP4pRV9d\VR,4pM\V!R44pRV9d\VR,4pM\V!R44pV!R4p\V!R 44p \ V4p \ WWgW4p WV3x\ R 4h5i) c&\RV,4#)zenv:// rendezvous: rdr]s&rre'_env_rendezvous_handler.._errorrrc<S!RV R24#)zenvironment variable z expected, but not setrw)varres&r _env_error+_env_rendezvous_handler.._env_errors-cU2HIJJrc0V^8dQhR\R\/#)renv_varrra)rs"rr-_env_rendezvous_handler..__annotate__ s33rch<\PPVR4pV'g S!V4hV#rT)r4r5r3)renv_valrs& r_get_env_or_raise2_env_rendezvous_handler.._get_env_or_raise s***..$/W% %Nrr9r?rAr@r{r|z3Unable to perform re-rendezvous using env:// method)rr'rr<r6rr)r8rrGrrHr)r9rA master_addr master_portr-rXrres&&, @@r_env_rendezvous_handlerrs>Kc]F -J:f%&$V,-z!L12 *<89 #M2K' 67K.z:I $G E  ## L MMsC Ctcpr>filec V^8dQh/^\9dI\\\R\\ \ \\3,,3,3,;R&#)r.r)__conditional_annotations__rrrrtupler r<)rs"rrrsC  $VUd3huUC_7M.N)N OOPU% r)rBrB)T)$r urllib.parserr ImportErrorerQr4r1collections.abcrrdatetimertorch.distributedrr r constantsr r__all__r r'r6rKr rZr_rqrxrrrrr)rs@rrs 1  .88)TVU (, 7+@P>> ? KN@M  - b$6NB$6-N`E#:;E#:;F$<=a  O    sB//C6 B??C