Nj 3 %SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJ r SSK J r J r SSK Jr SSKJr SSKJrJr SSKJrJr SSKJrJr SS KJrJr \R:"\5r\R@\!S '\"S S 9"S S55r"\"S S 9"SS55r#\"S S 9"SS55r$"SS\5r%S\&\'S\ \"4Sjr(S\&\'S\ \"4Sjr)S/S\'S\'S\*\&\'\ \"44Sjjr+S\'4Sjr,Sr-Sr.S r/"S!S"5r0"S#S$\5r1"S%S&\5r2"S'S(5r3S)\4S*\'S-S+\5S,\&\%S-\6\'SS4 S.jr7g)0N)ABCabstractmethod)CallableIterable)ThreadPoolExecutor) dataclass)BaseHTTPRequestHandlerThreadingHTTPServer)parse_qsurlparse) DictLoader Environment)get_world_sizetcpstore_clientloggerT)slotsc6\rSrSr%\\S'\\S'SrSrSr g)Response status_codetextcnURS:wa%[SURSUR35eg)NzHTTP z: )r RuntimeErrorrselfs r/root/GenerationalWealth/GenerationalWealth/venv/lib/python3.13/site-packages/torch/distributed/debug/_frontend.pyraise_for_statusResponse.raise_for_status!s8   s "t'7'7&8499+FG G #cB[R"UR5$N)jsonloadsrrs rr# Response.json%szz$))$$r N) __name__ __module__ __qualname____firstlineno__int__annotations__strrr#__static_attributes__r&r rrrs IH%r rc*\rSrSr%\\S'\\S'Srg)NavLink)pathlabelr&N)r'r(r)r*r-r,r.r&r rr0r0)s I Jr r0c6\rSrSr%\\S'\S/\4\S'Srg)Route/r2HTTPRequestHandlerhandlerr&N) r'r(r)r*r-r,rbytesr.r&r rr5r5/s I +,e3 44r r5c\rSrSr\S\\4Sj5r\S\\4Sj5r S\ \ \ 44Sjr S\ S-4Sjr S\ 4SjrS rg) DebugHandler5returncgr"r&rs rroutesDebugHandler.routes6s%(r cgr"r&rs r nav_linksDebugHandler.nav_links9s*-r c0$r"r&rs r templatesDebugHandler.templates<s r Ncgr"r&rs rdumpDebugHandler.dump?sr cH[U5RR5$r")typer'lowerrs r dump_filenameDebugHandler.dump_filenameBsDz""((**r r&)r'r(r)r*rlistr5r?r0rBdictr-rErHrMr.r&r rr;r;5s`(U ((-4=--4S>cDj+s+r r;urlsr=c^SSKmSnS[S[4U4Sjjn[US9nUR X 5nSSS5 U$!,(df  W$=f)Nrurlr=cf>TRU5n[URUR5$r")postrrr)rTresprequestss rgetfetch_thread_pool..getQs(}}S!(($))44r ) max_workers)rXr-rrmap)rQr[rYexecutorrespsrXs @rfetch_thread_poolr_KsTK555  4 S' 5 L 5 4 Ls A Ac^^SSKmSTRS[S[4SjmS[[S[ [4UU4Sjjn[ R"U"U55$)NrsessionrTr=c# URU5IShvN nUR5IShvN n[URU5sSSS5IShvN $NCN-N !,IShvN (df  g=f7fr")rVrrstatus)rarTrWrs rfetchfetch_aiohttp..fetch`sN<<$$$DDKK.%$$$%$$$sTA<AA<A"AA" A<A A<A" A<"A9(A+ ) A95A<rQc ># TR5IShvN n[R"UVs/sH nT"X5PM sn6IShvN sSSS5IShvN $NGs snfNN!,IShvN (df  g=f7fr") ClientSessionasynciogather)rQrarTaiohttprds rrifetch_aiohttp..gatheresY((**g )N#%*=)NOO+**)NO+***saBA BA+A" A+ A' A+ BA)B"A+)B+B1A4 2 B>B)rjrgr-rrOrrhrun)rQrirjrds @@r fetch_aiohttprm[sb/W22/// P49P();PP ;;vd| $$r endpointargsc>[5n[[55Vs/sHnSU3PM nnURU5nUVs/sHofR 5SUSU3PM nn[ U5nXW4$s snfs snf![ a [U5nXW4$f=f)Nrankz /handler/?)rranger multi_getdecoderm ImportErrorr_)rnrostorerkeysaddrsaddrr^s r fetch_allr|ls  E %n&6 7 8 71d1#J 7D 8 OOD !EFK Led iz4& 9eE L)e$ < 9 L )!%( <)sA8!A=* BBBblobcX[R"U5n[R"USS9$)N)indent)r#r$dumps)r}parseds r format_jsonrzs! ZZ F ::fQ ''r ac {% block title %}{% endblock %} - PyTorch Distributed
{% block header %}{% endblock %} {% block content %}{% endblock %}
a {% extends "base.html" %} {% block header %}

{% block title %}{{title}}{% endblock %}

{% endblock %} {% block content %} {% for i, (addr, resp) in enumerate(zip(addrs, resps)) %}

Rank {{ i }}: {{ addr }}

{% if resp.status_code != 200 %}

Failed to fetch: status={{ resp.status_code }}

{{ resp.text }}
{% else %} 
{{ resp.text }}
{% endif %} {% endfor %} {% endblock %} a {% extends "base.html" %} {% block header %}

{% block title %}{{ title }}{% endblock %}

{% endblock %} {% block content %} {% for i, (addr, resp) in enumerate(zip(addrs, resps)) %}

Rank {{ i }}: {{ addr }}

{% if resp.status_code != 200 %}

Failed to fetch: status={{ resp.status_code }}

{{ resp.text }}
{% else %} 
{{ format_json(resp.text) }}
{% endif %} {% endfor %} {% endblock %} c X\rSrSrS S\\S\S\SS4SjjrS Sjr S S jr S S jr S r g)PeriodicDumperhandlers output_dirinterval_secondsr=NcjXlX lX0l[R"5UlSUlgr") _handlers _output_dir_interval_seconds threadingEvent _stop_event_thread)rrrrs r__init__PeriodicDumper.__init__s+ "%!1$??,04 r c[R"URSS9 [R"UR SSS9UlUR R5 g)NT)exist_okz distributed.debug.PeriodicDumper)targetdaemonname)osmakedirsrrThread_runrstartrs rrPeriodicDumper.startsG D$$t4 ''993  r cURR5 URbURR5 ggr")rsetrjoinrs rstopPeriodicDumper.stops3  << # LL    $r cURR5(dURHnUR5nUcM[R"S5nUR5SUS3n[RRURU5n[US5nURU5 SSS5 M URR!UR"5 URR5(dMgg![a) [ R SUR55 GMf=f!,(df  GM(=f![a [ R SU5 GMOf=f)NzFailed to dump %sz %Y%m%d_%H%M%S_z.txtwzFailed to write dump to %s)ris_setrrH Exceptionr exceptionrMtimestrftimerr2rropenwritewaitr)rr8content timestampfilenamer2fs rrPeriodicDumper._run s4""))++>>%llnG? MM/: %3356a {$Gww||D$4$4h?IdCA()*    ! !$"8"8 9#""))++!$$%8':O:O:QR) I$$%A4HHIsAD E(E:E.EE E EE E<;E<)rrrrr)gN@r=N) r'r(r)r*rOr;r-floatrrrrr.r&r rrrsF #' 5|$ 5 5 5  5 :r rcZ\rSrSr%\R r\R\S'Sr \ \S'Sr g)_IPv6HTTPServeri#address_familyirequest_queue_sizer&N) r'r(r)r*socketAF_INET6r AddressFamilyr,rr+r.r&r rrr#s!+1??NF((:""r rc \rSrSr%S\S'SrSrS\4SjrS\ \\ \44Sjr S\4S jr S \4S \S \ S \S\ 4SjjrSrg )r7i(FrontendServerfrontendcP[RSURSX-5 g)Nz%s %sr)rinfoclient_address)rformatros r log_messageHTTPRequestHandler.log_message+s$     " M r c:URRU5 gr")r_handle_requestrs rdo_GETHTTPRequestHandler.do_GET2s %%d+r r=c@[UR5R$r")r r2rs rget_pathHTTPRequestHandler.get_path5s "'''r c4[UR55$r")r get_raw_queryrs r get_queryHTTPRequestHandler.get_query8s**,--r c@[UR5R$r")r r2queryrs rr HTTPRequestHandler.get_raw_query;s "(((r NrdefaultrKcJUR5nX;aU$U"XAS5$)Nr)r)rrrrKrs r get_query_arg HTTPRequestHandler.get_query_arg>s,   NEKN##r r&)r'r(r)r*r,rrr-rrPrOrrobjectrKrr.r&r rr7r7(st ,(#(.4T#Y/.)s),0c$$"($7;$ $$r r7ct\rSrSrSS\S\\S-4SjjrSSjrSSjr S \ SS4S jr S \ S \ S\4S jrSrg)riGNportrcUc SSKJn U"5nSRSU55n[[[ S.nUH"nUR UR55 M$ [U5n[USS9Ul URRR [[[US9 0UlUH=nUR!5H&nUR"URUR$'M( M? X l[)S [*4S U05n S U4n [-X5Ul[0R2"UR4S SS S9UlUR6R95 g)Nr)default_handlers c3# UH:nUR5H"nSURSURS3v M$ M< g7f)z z N)rBr2r3).0r8links r *FrontendServer.__init__..SsF #))+DII;b 4L M+ N#sAA)z base.htmlz raw_resp.htmlzjson_resp.htmlT)loader enable_async)zipr enumeraterBr7rr&z distributed.debug.FrontendServer)rrorr)'torch.distributed.debug._debug_handlersrr BASE_TEMPLATERAW_RESP_TEMPLATEJSON_RESP_TEMPLATEupdaterEr r _jinja_envglobalsrrr_routesr?r8r2rrKr7r_serverrr_serverr) rrrrnav_html all_templatesr8rrouteRequestHandlerClassserver_addresss rrFrontendServer.__init__HsV   P')H99 #  '.0)  G  !2!2!4 5 M*%V$G &&# ' JL G )+0== UZZ(* "#  !    d&~K  '';;3   r r=cURR5 g![a [R S5 gf=f)Nz got exception in frontend server)r serve_foreverrrrrs rrFrontendServer._serves8 A LL & & ( A   ? @ As ??c8URR5 gr")rrrs rrFrontendServer.joins r reqcUR5nX R;aURSSU35 gURUnU"U5nURS5 URSS5 UR5 URRU5 g![[4a>n[ R SU5 URSS[U535 SnAgSnAff=f) NizHandler not found: z-Exception in frontend server when handling %siz Exception: rz Content-typez text/html) rr send_errorr SystemExitrrrepr send_response send_header end_headerswfiler)rrr2r8rWes rrFrontendServer._handle_requests||~ || # NN3"5dV < = ,,t$ 3r&s   #.1!C+*J!**844  % % %   555 +3+, DI (8*<  %S %hx&8%"  3 d3i(AS6S0T (c(> @$0-:-:j#)# $/$>_P_PD" "Dj""< " s8 "  "r