+ j5< a0t$^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI H t ^RI HtHtHtHtHt^RIHt^RIHt^RIHt^RIHt] P6'd^R IHt^RIt]P@!]!4t"]PF!4'd^R I$H%t&]&t%R ]'R &M](]),t%R ]'R &]!R 4t*]!R4t+]PX!]RRRRRR7t-]PX!]RRRRRR7t.!RR]]*,4t/!RR]]*]+3,4t0]]1]2]3]4]5]3R3,]6R,R3,t7R ]'R&!RR]0]7]83,4t9!RR ]0]*]*3,4t:!R!R"]/]8,4t;!R#R$]]*,4t<!R%R&]/]8,4t=!R'R(]<]7,4t>!R)R*]<]7,4t?!R+R,]?4t@!R-R.]>4tA!R/R0]>4tB!R1R2]>4tC!R3R4]>4tD!R5R6]>4tER@R7R/R8R9llltF]P!R:R;44tH!R<R=4tI]I!4tJ]PR>R?l4tLR# ]dRtELi;i)A) annotationsN)abstractmethod)AnyGeneric TypeAliasTypeVarUnion)override) dynamo_timed)config) _WaitCounter)Callable)Samplerr_T_UzFbRemoteFxGraphCache.getremote_fx_graph_cache_getF!remote_fx_graph_cache_get_time_usT) phase_namelog_pt2_compile_eventdynamo_compile_column_uslog_waitcounterzFbRemoteFxGraphCache.putremote_fx_graph_cache_put!remote_fx_graph_cache_put_time_uscj]tRt^BtRtRRlt]RRl4t]RRl4tRR lt R R lt R t R #)RemoteCacheBackendz A backend implementation for cache storage. Most backends are remote, but local filesystem backends use the same bytes-oriented interface. For structured data use a RemoteCache. cV^8dQhRR/#returnNone)formats"]/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/_inductor/remote_cache.py __annotate__RemoteCacheBackend.__annotate__Is66$6c @R\V4P 2VnR#)zbackend:N)type__name___nameselfs&r#__init__RemoteCacheBackend.__init__IsT 3 345 r&c V^8dQhRRRR/#rkeystrr _T | Noner!)r"s"r#r$r%Ms    r&c R#Nr!r,r1s&&r#_getRemoteCacheBackend._getL r&c$V^8dQhRRRRRR/#rr1r2datarrr r!)r"s"r#r$r%Qs!   2 $ r&c R#r5r!r,r1r<s&&&r#_putRemoteCacheBackend._putPr9r&c V^8dQhRRRR/#r0r!)r"s"r#r$r%Tssyr&c VPV4p\PVPV4V# \d"\P TP4hi;ir5)r7 cache_statsgetr* Exception exceptionr,r1values&& r#rDRemoteCacheBackend.getTsS IIcNE OODJJ .    ! !$** -  s 15,A!c$V^8dQhRRRRRR/#r;r!)r"s"r#r$r%]s!s"r&c VPW4\PVP4R# \d"\P TP4hi;ir5)r?rCputr*rErFr>s&&&r#rLRemoteCacheBackend.put]sG  IIc OODJJ '   ! !$** -  s 04,A )r*N) r) __module__ __qualname____firstlineno____doc__r-rr7r?rDrL__static_attributes__r!r&r#rrBsC 6    r&rcB]tRt^gt]RRl4t]RRl4tRtR#)RemoteCacheSerdec V^8dQhRRRR/#)rr<rrrr!)r"s"r#r$RemoteCacheSerde.__annotate__i  2 " r&c R#r5r!r,r<s&&r#encodeRemoteCacheSerde.encodehr9r&c V^8dQhRRRR/#)rr<rrrr!)r"s"r#r$rVmrWr&c R#r5r!rYs&&r#decodeRemoteCacheSerde.decodelr9r&r!N)r)rNrOrPrrZr^rRr!r&r#rTrTgs(    r&rT JsonDataTyc.]tRt^vtRRltRRltRtR#)RemoteCacheJsonSerdec V^8dQhRRRR/#)rr<r`rbytesr!)r"s"r#r$!RemoteCacheJsonSerde.__annotate__ws00:0%0r&c B\\P!V4R4#)ascii)rdjsondumpsrYs&&r#rZRemoteCacheJsonSerde.encodewsTZZ%w//r&c V^8dQhRRRR/#)rr<rdrr`r!)r"s"r#r$rezs  5 Z r&c .\P!V4#r5)rhloadsrYs&&r#r^RemoteCacheJsonSerde.decodezszz$r&r!Nr)rNrOrPrZr^rRr!r&r#rbrbvs0  r&rbc.]tRt^~tRRltRRltRtR#)RemoteCachePassthroughSerdec V^8dQhRRRR/#rr<rrr!)r"s"r#r$(RemoteCachePassthroughSerde.__annotate__2"r&c V#r5r!rYs&&r#rZ"RemoteCachePassthroughSerde.encode r&c V^8dQhRRRR/#rsr!)r"s"r#r$rtrur&c V#r5r!rYs&&r#r^"RemoteCachePassthroughSerde.decoderxr&r!Nror!r&r#rqrq~sr&rqcF]tRt^tRt]RRl4t]RRl4tRtR#)LocalCacheBackendzC A local filesystem implementation of the cache backend interface. c V^8dQhRRRR/#rr1r2rz bytes | Noner!)r"s"r#r$LocalCacheBackend.__annotate__s r&c \VR4;_uu_4pVP4uuRRR4# +'giR#;i \dR#i;i)rbN)openreadFileNotFoundError)r,r1fds&& r#r7LocalCacheBackend._gets: c4Bwwy!   s*A1 A A AA AAc$V^8dQhRRRRRR/#rr1r2r<rdrr r!)r"s"r#r$rs!***5*T*r&c \P!\PPV4RR7^RIHpVP W4R#)T)exist_ok) codecacheN)osmakedirspathdirnametorch._inductorr write_atomic)r,r1r<rs&&& r#r?LocalCacheBackend._puts. BGGOOC(48-s)r&r!N) r)rNrOrPrQr r7r?rRr!r&r#r}r}s/**r&r}c]tRt^t$RtR]R&RRltRRltRR ltR R lt R R lt RRlt RRlt RRlt RRltRRltRRltRtR#) RemoteCacheNz,Callable[[], RemoteCacheBackend[Any]] | Nonebackend_override_clsc$V^8dQhRRRRRR/#)rbackendzRemoteCacheBackend[_U]serdezRemoteCacheSerde[_T, _U]rr r!)r"s"r#r$RemoteCache.__annotate__s$  - 6N   r&c lVPP;peV!4VnMWnW nR#r5) __class__rrr)r,rr override_clss&&& r#r-RemoteCache.__init__s,!NN?? ?L L'>DL"L r&c V^8dQhRRRR/#r0r!)r"s"r#r$rs  s y r&c \R4P4;_uu_4VP4pVPW4p\P \ V4PV4TPT4TuuRRR4# \dGp\P\ T4P4T'd\T4Tn hRp?ii;i TPT4i;i +'giR#;i)zpytorch.remote_cache.getN) r guard_create_sampler7rCrDr(r)rErFr2 fail_reason _log_sample)r,r1sampleresultes&& r#rDRemoteCache.gets 4 5 ; ; = =((*F )3/T 3 3V<  (> =  %%d4j&9&9:),QF&     (> = =s;C6:B /C6 CACCC  C33C66 D c$V^8dQhRRRRRR/#)rr1r2rHrrr r!)r"s"r#r$rs!))s)2)$)r&c 0\R4P4;_uu_4Vf \R4hVP4pVP WV4\ P \V4P4TPT4RRR4R# \dGp\ P\T4P4T'd\T4Tn hRp?ii;i TPT4i;i +'giR#;i)zpytorch.remote_cache.putNzcannot put None into the cache)r rAssertionErrorrr?rCrLr(r)rErFr2rr)r,r1rHrrs&&& r#rLRemoteCache.puts 4 5 ; ; = =}$%EFF((*F ) #f-T 3 34  (> = %%d4j&9&9:),QF&     (> = =s< D:B>D C+%AC&&C++C..DD D c$V^8dQhRRRRRR/#)rr<rr Sample | Nonerrr!)r"s"r#r$rs!''B' '"'r&c 8VPPV4#r5)rr^)r,r<rs&&&r#_decodeRemoteCache._decodeszz  &&r&c$V^8dQhRRRRRR/#)rrHrrrrobjectr!)r"s"r#r$rs!((R((6(r&c 8VPPV4#r5)rrZ)r,rHrs&&&r#_encodeRemoteCache._encodeszz  ''r&c$V^8dQhRRRRRR/#)rr1r2rrrr3r!)r"s"r#r$rs!]yr&c ZVPV4;p'dVPW24#R#r5) _backend_getr)r,r1rr<s&&& r#r7RemoteCache._gets*$$S) )4 )<<- -r&c V^8dQhRRRR/#)rr1r2rrr!)r"s"r#r$rs%%%%r&c 8VPPV4#r5)rrDr6s&&r#rRemoteCache._backend_gets||$$r&c(V^8dQhRRRRRRRR/#) rr1r2rHrrrrr r!)r"s"r#r$rs(%%%B% %$%r&c JVPW#4pVPW4R#r5)r _backend_put)r,r1rHrr<s&&&& r#r?RemoteCache._puts||E* #$r&c$V^8dQhRRRRRR/#)rr1r2r<rrr r!)r"s"r#r$rs!$$$6$d$r&c <VPPW4R#r5)rrLr>s&&&r#rRemoteCache._backend_puts #r&cV^8dQhRR/#)rrrr!)r"s"r#r$rs r&c R#r5r!r+s&r#rRemoteCache._create_samplesr&c V^8dQhRRRR/#)rrrrr r!)r"s"r#r$r s  - D r&c R#r5r!)r,rs&&r#rRemoteCache._log_sample s r&)rr)r)rNrOrPr__annotations__r-rDrLrrr7rr?rrrrRr!r&r#rrsJIMFM  $)"'( % %$   r&rcna]tRtRt$RtRtR]R&RV3Rllt]RR l4t ]R R l4t R t V;t #) RedisRemoteCacheBackendiz7 A Redis implementation of a remote/distributed cache. Nzredis.Redis | None_redisc V^8dQhRRRR/#rcache_idr2rr r!)r"s"r#r$$RedisRemoteCacheBackend.__annotate__s    r&c  <\SV`4\'g \R4hR\P 9d<\P P\P R,4VnR#\P !\P PRR4\\P PRR44R7VnR#)z1redis not available but required for remote cacheTORCHINDUCTOR_REDIS_URLTORCHINDUCTOR_REDIS_HOST localhostTORCHINDUCTOR_REDIS_PORTi)hostportN) superr-redis RuntimeErrorrenvironRedisfrom_urlrrDint)r,rrs&&r#r- RedisRemoteCacheBackend.__init__s uRS S $ 2++..rzz:S/TUDK++ZZ^^$> L(BDIJDKr&c V^8dQhRRRR/#rr!)r"s"r#r$r%s r&c "VP'gR#VPPV4pTe.\ T\ 4'g\R\T4 24hT# \PPd RTnR#i;i)Nzexpected bytes or None, got ) rrDr exceptionsConnectionError isinstancerdrr(rGs&& r#r7RedisRemoteCacheBackend._get$s}{{{ KKOOC(E E5!9!9 #?U }!MN N // DK  sA$$&B Bc$V^8dQhRRRRRR/#rr!)r"s"r#r$r:s!   5 T r&c VP'gR#VPPW4R# \PPd RTnR#i;ir5)rsetrrrr>s&&&r#r?RedisRemoteCacheBackend._put9sG{{{   KKOOC &// DK s3&AA)r) r)rNrOrPrQrrr-r r7r?rR __classcell__rs@r#rrsG "&F %  (  r&rcra]tRtRtRV3RlltRRlt]RV3Rll4t]RV3R ll4tR t V;t #) RedisRemoteCacheiIc V^8dQhRRRR/#rr!)r"s"r#r$RedisRemoteCache.__annotate__Js > > > >r&c <VPP'd(\P!\\ ,R4pM \ V4p\4p\SV`%W#4^pRV RV 2Vn R#)Nzpt2:z ::{key}:c) rrtypingcastrrdrrbrr-_key_fmt)r,rrrversionrs&& r#r-RedisRemoteCache.__init__Jsc >> . . .kk"4U";TBG-h7G$& (xj G9= r&c V^8dQhRRRR/#)rr1r2rr!)r"s"r#r$rWs--C-C-r&c :VPPVR7#))r1)rr"r6s&&r#_get_keyRedisRemoteCache._get_keyWs}}###,,r&c$V^8dQhRRRRRR/#rr1r2rrrzJsonDataTy | Noner!)r"s"r#r$r[s")))])7H)r&c D<VPV4p\SV` W4#r5)rrr7)r,r1rrs&&&r#r7RedisRemoteCache._getZs mmC w|C((r&c(V^8dQhRRRRRRRR/#) rr1r2rHr`rrrr r!)r"s"r#r$r`s()))J) )$)r&c J<VPV4p\SV` WV4R#r5)rrr?)r,r1rHrrs&&&&r#r?RedisRemoteCache._put_smmC   S(r&)r) r)rNrOrPr-rr r7r?rRrrs@r#rrIs: > >-))))r&rcJa]tRtRtRV3Rllt]RV3Rll4tRtV;t#) LocalCacheiec V^8dQhRRRR/#rr!)r"s"r#r$LocalCache.__annotate__fs))))r&c N<\4p\4p\SV` W#4R#r5)r}rbrr-)r,rrrrs&& r#r-LocalCache.__init__fs"$%$& (r&c$V^8dQhRRRRRR/#rr!)r"s"r#r$ros"   ] 7H r&c <\SV`W4# \P\3d7p\ P RT\T4PT4Rp?R#Rp?ii;i)z-Ignoring corrupt local cache entry %s: %s: %sN) rr7rhJSONDecodeErrorUnicodeDecodeErrorlogwarningr(r))r,r1rexcrs&&& r#r7LocalCache._getnsZ 7<, ,$$&89  KK?S ""    sA#+AA#r!) r)rNrOrPr-r r7rRrrs@r#rres!))  r&rc]tRtRtRtR#)LocalAutotuneCachei|r!Nr)rNrOrPrRr!r&r#rr|sr&rc]tRtRtRtR#)RemoteAutotuneCacheir!Nrr!r&r#rrr&rc]tRtRtRtR#)RemoteBundledAutotuneCacheir!Nrr!r&r#rrrr&rc]tRtRtRtR#)RemoteFxGraphCacheir!Nrr!r&r#rrrr&rc]tRtRtRtR#)RemoteAOTAutogradCacheir!Nrr!r&r#rrrr&rc]tRtRtRtR#)RemoteDynamoPGOCacheir!Nrr!r&r#rrrr&rlocal_cache_clsc 0V^8dQhRRRRRRRRRRR R /#) rr1r2 is_fbcodebool fb_cache_clsz str | None oss_cache_clsrrzRemoteCache[JsonDataTy] | Noner!)r"s"r#r$r$sD    $r&c\P\,pVe\WT4pV!V4#V'dFVf \ R4h^RIp\VP PPV4pV!V4#Vf \ R4h\WS4pV!V4# \d\PRRR7R#i;i)Nz'fb_cache_cls must not be None in fbcodezoss_cache_cls must not be NonezUnable to create cacheT)exc_info) sysmodulesr)getattrrtorch._inductor.fb.remote_cache _inductorfb remote_cacherEr r)r1r!r#r$r this_module cache_clstorchs&&&&$ r# create_cacher1skk(+  & =IS> ! #$%NOO 2 2 2 ? ?NIS> !$$%EFF ;IS> !  ,t <s"1B#B#AB#!B##"C C c\]tRtRt$^tR]R&^tR]R&^tR]R&^tR]R&RRlt R t R #) _CacheStatirmisshitrLrFcV^8dQhRR/#)rrr2r!)r"s"r#r$_CacheStat.__annotate__sgggr&c  pRVP RVP RVP RVP R2 #)z{hit: z, miss: z, put: z , exception: })r5r4rLrFr+s&r#__str___CacheStat.__str__s8 (499+WTXXJmTXTbTbScceffr&r!N) r)rNrOrPr4rr5rLrFr:rRr!r&r#r3r3s3D#MCLCLIsggr&r3cz]tRtRt$R]R&RRltRRRlltRRR lltR R ltRR R llt RRRllt Rt R#) _CacheStatsizdict[str, _CacheStat]_statscV^8dQhRR/#rr!)r"s"r#r$_CacheStats.__annotate__s::$:r&c D\P!\4VnR#r5) collections defaultdictr3r>r+s&r#r-_CacheStats.__init__s!--j9 r&c$V^8dQhRRRRRR/#rnamer2countrrr r!)r"s"r#r$r@s!(((S((r&c ZVPV,;PV, unR#r5)r>r4r,rGrHs&&&r#r4_CacheStats.misss D%'r&c$V^8dQhRRRRRR/#rFr!)r"s"r#r$r@!'''C''r&c ZVPV,;PV, unR#r5)r>r5rJs&&&r#r5_CacheStats.hit D&r&c$V^8dQhRRRRRR/#)rrGr2rHz object | Nonerr r!)r"s"r#r$r@s!Mdr&c VVfVPV4R#VPV4R#r5)r4r5)r,rGrHs&&&r#rD_CacheStats.gets = IIdO HHTNr&c$V^8dQhRRRRRR/#rFr!)r"s"r#r$r@rMr&c ZVPV,;PV, unR#r5)r>rLrJs&&&r#rL_CacheStats.putrPr&c$V^8dQhRRRRRR/#rFr!)r"s"r#r$r@s!--c-#-d-r&c ZVPV,;PV, unR#r5)r>rFrJs&&&r#rF_CacheStats.exceptions D##u,#r&)r>N)) r)rNrOrPrr-r4r5rDrLrFrRr!r&r#r=r=s+ !!:(' '--r&r=cV^8dQhRR/#rr!)r"s"r#r$r$s11$1r&c\P\P4'gR#^RIpVP 4p\ P'g\RVR7MO\VR7\\ PP44Fwr#\RV RV 2VR7K \PRVP44R#)Nz None)filez z: zCache Metrics:%s) r  isEnabledForloggingINFOioStringIOrCr>printsorteditemsinfogetvalue)raoutkvs r#dump_cache_statsrks   GLL ) ) ++-C     gC  3;--3356DA BqcA3-c *7HH 0r&)FNN)M__conditional_annotations__ __future__ratexitrB dataclasses functoolsrhr_rr'rabcrrrrrr typing_extensionsr torch._dynamo.utilsr rr torch.monitorr TYPE_CHECKINGcollections.abcrr ImportError getLoggerr)r r!rfe.scubadata.scubadata_py3rSample_rr(rrrpartialremote_fx_cache_get_timedremote_fx_cache_put_timedrrTrfloatr2r"dictlistr`rdrbrqr}rrrrrrrrrrr1 dataclassr3r=rCregisterrk)rls@r#rs""   ::&,"& ( !  FIV FI$ T] T]&--*@ &--*@ !!J wr2v T4\ 12D4FL I  +J,=> "22r6":**51*XZ '"+Z z7077t){:.)8Z(.   *  !1  )  -  +  #' @ ggg--2m 11E Es4I I&%I&