ó
    Eñi“E  ã            	       ó   • S SK r S SKJr  S SKJrJr  S SKrS SKJr  S SK	J
r
  S SKJrJr  SSKJr  SS	KJr  SS
KJrJr  SSKJrJr  SSKJr  SSKJr  SSKJrJr  SSKJ r   SSK!J"r"  \(       a  S SK#J$r$  SSK%J&r&  S SK'J(r(  \RR                  r)S\S\S\*4S jr+S\,\   S\S\*4S jr-S\R\                  SSSS4S jr/S\R\                  S\*4S jr0S\*S\Rb                  4S  jr2S\*S\Rf                  4S! jr4\(" S"S#S$9S%\*S&\*SS4S' j5       r5\5Rl                  S%\*S&\*SS4S( j5       r7\" \Rp                  Rr                  Rt                  Rv                  5        \(" S)S#S$9S%\*S&\*SS4S* j5       r<\<Rl                  S%\*S&\*SS4S+ j5       r7\" \Rp                  Rr                  Rz                  Rv                  5        \(" S,S#S$9S-\*S.\*SS4S/ j5       r>\>Rl                  S-\*S.\*SS4S0 j5       r7\" \Rp                  Rr                  R|                  Rv                  5        \(" S1S#S$9S-\*S.\*SS4S2 j5       r?\?Rl                  S-\*S.\*SS4S3 j5       r7\" \Rp                  Rr                  R~                  Rv                  5        \(" S4S#S$9S5\*S6\*SS4S7 j5       r@\@Rl                  S-\*S.\*SS4S8 j5       r7\" \Rp                  Rr                  R€                  Rv                  5        \(" S9S#S$9S:\*S;\*S<\RR                  SS4S= j5       rA\" \Rp                  Rr                  R‚                  Rv                  5        \(" S>S#S$9S?\RR                  S.\*SS4S@ j5       rB\BRl                  S;\*S:\*S<\RR                  SS4SA j5       r7 " SB SC5      rC " SD SE\ 5      rD " SF SG\D5      rE " SH SI\5      rFg)Jé    N)ÚCallable)ÚAnyÚOptional)ÚConstDictVariable)ÚTupleVariable)Úhas_side_effectÚProxyé   )Úgraph_break_hints)Úcreate_call_function)ÚTYPE_CHECKINGÚunimplemented)Úget_external_object_by_indexÚregister_graph_created_object©ÚCurrentStreamSourceé   )ÚVariableTracker)ÚCONSTANT_VARIABLE_NONEÚConstantVariable)ÚFxTracebackAnnotateVariable)ÚLazyVariableTracker)ÚInstructionTranslator)Ú	PyCodegen)Ú	custom_opÚargsÚkwargsÚreturnc            	      ó’   • [         R                  " U 0 UD6n[        U[        R	                  [        / 5      [        0 5      5      5      $ ©N)ÚtorchÚEventr   ÚEventVariableÚ make_construct_in_graph_event_fnr   r   )r   r   Úevents      Ú\/home/mande/repo/quber/.venv/lib/python3.13/site-packages/torch/_dynamo/variables/streams.pyÚ	new_eventr'   #   sC   € Ü�KŠK˜Ð( Ñ(€EÜ(ØÜ×6Ñ6Ü˜"ÓÔ0°Ó4ó	
óð ó    c            	      ó’   • [         R                  " U 0 UD6n[        U[        R	                  [        / 5      [        0 5      5      5      $ r    )r!   ÚStreamr   ÚStreamVariableÚ!make_construct_in_graph_stream_fnr   r   )r   r   Ústreams      r&   Ú
new_streamr.   -   sC   € Ü�\Š\˜4Ð* 6Ñ*€FÜ(ØÜ×8Ñ8Ü˜"ÓÔ0°Ó4ó	
óð r(   ÚdeviceÚcgr   c                 óˆ   ^• TR                  U4S j5        T" [        U 5      5        TR                  [        SS5      5        g )Nc                  ól   >• T R                  [        R                  R                  R                  S5      $ ©NÚstash_graph_created_object©Úload_import_fromr!   Ú_dynamoÚgraph_bytecode_inputsÚ__name__)r0   s   €r&   Ú<lambda>Ú)_codegen_current_stream.<locals>.<lambda>9   s&   ø€ �×#Ñ#Ü�M‰M×/Ñ/×8Ñ8Ø(ô
r(   r   F)Úadd_push_nullr   Úextend_outputr   )r/   r0   s    `r&   Ú_codegen_current_streamr>   7   s<   ø€ Ø×Ñô	
ôñ Ô˜6Ó"Ô#Ø×ÑÔ)¨!¨UÓ3Õ4r(   c                 ób   ^ • [         R                  R                  T 5      n[        UU 4S j5      $ )Nc                 ó   >• [        TU5      $ r    )r>   )Ú_r0   r/   s     €r&   r:   Ú$get_current_stream.<locals>.<lambda>E   s   ø€ Ô5°f¸bÔAr(   )r!   ÚacceleratorÚcurrent_streamr   )r/   r-   s   ` r&   Úget_current_streamrE   B   s,   ø€ Ü×Ñ×-Ñ-¨fÓ5€FÜ(ØÔAóð r(   Úindexc                 ón   • [        U 5      n[        U[        R                  5      (       d
   SU  35       eU$ )Nz3Fork/join stream expected a stream object at index )r   Ú
isinstancer!   r*   )rF   r-   s     r&   Ú_get_stream_by_indexrI   I   s;   € Ü)¨%Ó0€FÜ�fœeŸl™l×+Ñ+ð Ø
=¸e¸WÐEóÐ+ð €Mr(   c                 ón   • [        U 5      n[        U[        R                  5      (       d
   SU  35       eU$ )Nz4Record/wait event expected an event object at index )r   rH   r!   r"   )rF   r%   s     r&   Ú_get_event_by_indexrK   Q   s;   € Ü(¨Ó/€EÜ�eœUŸ[™[×)Ñ)ð Ø
>¸u¸gÐFóÐ)ð €Lr(   zstreams::fork© )Úmutates_argsÚ
from_indexÚto_indexc                 óT   • [         R                  R                  [        U5      5        g r    ©r!   rC   Ú
set_streamrI   ©rN   rO   s     r&   Úfork_streamrT   Y   s   € ô
 
×Ñ× Ñ Ô!5°hÓ!?Õ@r(   c                 ó   • g r    rL   rS   s     r&   rA   rA   a   ó   € ð
 	r(   zstreams::joinc                 óT   • [         R                  R                  [        U5      5        g r    rQ   rS   s     r&   Újoin_streamrX   l   s   € ä	×Ñ× Ñ Ô!5°hÓ!?Õ@r(   c                 ó   • g r    rL   rS   s     r&   rA   rA   q   rV   r(   zstreams::record_eventÚevent_indexÚstream_indexc                 óR   • [        U 5      n[        U5      nUR                  U5        g r    )rK   rI   Úrecord_event©rZ   r[   r%   r-   s       r&   r]   r]   |   s$   € ä Ó,€EÜ! ,Ó/€FØ
×Ñ˜Õr(   c                 ó   • g r    rL   ©rZ   r[   s     r&   rA   rA   ƒ   rV   r(   zstreams::wait_eventc                 óR   • [        U 5      n[        U5      nUR                  U5        g r    )rK   rI   Ú
wait_eventr^   s       r&   rb   rb   Ž   s$   € ä Ó,€EÜ! ,Ó/€FØ
×Ñ�eÕr(   c                 ó   • g r    rL   r`   s     r&   rA   rA   •   rV   r(   zstreams::wait_streamÚwaiting_stream_indexÚwaited_on_stream_indexc                 óR   • [        U 5      n[        U5      nUR                  U5        g r    )rI   Úwait_stream)rd   re   ÚwaitingÚ	waited_ons       r&   rg   rg       s&   € ä"Ð#7Ó8€GÜ$Ð%;Ó<€IØ×Ñ˜	Õ"r(   c                 ó   • g r    rL   r`   s     r&   rA   rA   §   rV   r(   zstreams::sync_deallocÚwait_event_indexÚsrc_stream_indexÚ
to_deallocc                 ój   • [         R                  R                  R                  R	                  X5        g)au  An op which waits on an event and moves the last usage of to_dealloc
after the wait, so that after the sync occurs, the deallocation or
subsequent reuse of the tensor's memory will be guaranteed to happen
after a side stream is finished using it.
See https://docs.pytorch.org/docs/stable/generated/torch.Tensor.record_stream.html#torch.Tensor.record_stream
for more detailsN)r!   ÚopsÚstreamsrb   Údefault)rk   rl   rm   s      r&   Úsync_deallocrr   ²   s#   € ô 
‡I�I×Ñ× Ñ ×(Ñ(Ð)9ÕLr(   zstreams::record_streamÚtensorc                 ó8   • U R                  [        U5      5        g r    )Úrecord_streamrI   )rs   r[   s     r&   ru   ru   Â   s   € à
×ÑÔ-¨lÓ;Õ<r(   c                 ó   • g r    rL   )rl   rk   rm   s      r&   rA   rA   Ç   s   € ð 	r(   c                   ót   • \ rS rSrSrSS jrSS jrSS jrSS	\\	R                     SS4S
 jjrS\4S jrSrg)ÚSymbolicStreamStateéÐ   z)Track the currently entered stream if anyr   Nc                 óP  • SSK Jn  / n[        R                  R	                  5       (       a`  [
        R                  " [        R                  R                  5       U" [        R                  R                  5       R                  5      S9nU/n[        R                  " U5      U l        g )Nr
   r   )Úsource)r{   r   r!   rC   Úis_availabler   ÚcreaterD   r/   ÚcollectionsÚdequeÚcur_stream_stack)Úselfr   Ú	cur_stackÚ
stream_vars       r&   Ú__init__ÚSymbolicStreamState.__init__Ó   s~   € Ý0à*,ˆ	Ü×Ñ×)Ñ)×+Ñ+Ü,×3Ò3Ü×!Ñ!×0Ñ0Ó2Ù*¬5×+<Ñ+<×+KÑ+KÓ+M×+TÑ+TÓUñˆJð $˜ˆIäCN×CTÒCTØóD
ˆÕr(   r+   c                 ó:   • U R                   R                  U5        g r    )r€   Úappend)r�   r-   s     r&   Úenter_streamÚ SymbolicStreamState.enter_streamâ   s   € Ø×Ñ×$Ñ$ VÕ,r(   c                 ó8   • U R                   R                  5         g r    )r€   Úpop©r�   s    r&   Úexit_streamÚSymbolicStreamState.exit_streamå   s   € Ø×Ñ×!Ñ!Õ#r(   r/   c                 ó†   • Ub0  [        U R                  5       H  nUR                  U:X  d  M  Us  $    U R                  S   $ )Néÿÿÿÿ)Úreversedr€   r/   )r�   r/   r-   s      r&   Ú
cur_streamÚSymbolicStreamState.cur_streamè   sA   € ØÑÜ" 4×#8Ñ#8Ö9�Ø—=‘= FÕ*Ø!’Mñ :ð ×$Ñ$ RÑ(Ð(r(   c                 ó2   • [        U R                  5      S:„  $ )Nr   )Úlenr€   rŒ   s    r&   Úin_stream_contextÚ%SymbolicStreamState.in_stream_contextð   s   € Ü�4×(Ñ(Ó)¨AÑ-Ð-r(   )r€   )r   N)r-   r+   r   Nr    )r9   Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r„   rˆ   r�   r   r!   r/   r’   Úboolr–   Ú__static_attributes__rL   r(   r&   rx   rx   Ð   s=   † Ù3ô
ô-ô$ñ) ¨%¯,©,Ñ!7ð )ÐCSõ )ð. 4÷ .r(   rx   c            	       óÀ   ^ • \ rS rSrSr\SSSSS\\\4   SS 4S	 j5       r	S
\
S   S\SS4U 4S jjrSSS\S\4U 4S jjrSSS\S\4U 4S jjrS\4S jrSS jrSrU =r$ )ÚStreamContextVariableéô   z(This represents torch.cuda.StreamContextÚtxr   Ústream_to_enterr+   r   r   c                 ó   • [        U40 UD6$ r    )rŸ   )r¡   r¢   r   s      r&   r}   ÚStreamContextVariable.create÷   s   € ô %Øñ
àñ
ð 	
r(   r-   Nc                 ól   >• Xl         [        TU ]  " SSU R                  5       R                  0S S.UD6  g )Nr-   )Útarget_valuesÚinitial_valuesrL   )r-   Úsuperr„   Ú
get_streamÚuser_object_index)r�   r-   r   Ú	__class__s      €r&   r„   ÚStreamContextVariable.__init__  s<   ø€ ØŒÜ‰Òð 	
Ø# T§_¡_Ó%6×%HÑ%HÐIØñ	
ð ó	
r(   r   c                 ót   >• UR                   R                  U R                  5       5        [        TU ]  U5      $ r    )Úsymbolic_stream_staterˆ   r©   r¨   Úenter©r�   r¡   r   r«   s      €r&   r¯   ÚStreamContextVariable.enter
  s/   ø€ ð
 	× Ñ ×-Ñ-¨d¯o©oÓ.?Ô@Ü‰w‰}˜RÓ Ð r(   c                 óZ   >• UR                   R                  5         [        TU ]  " U/UQ76 $ r    )r®   r�   r¨   Úexitr°   s      €r&   r³   ÚStreamContextVariable.exit  s+   ø€ ð
 	× Ñ ×,Ñ,Ô.Ü‰wŠ|˜BÐ& Ò&Ð&r(   c                 ó   • g)NTrL   rŒ   s    r&   Úsupports_graph_breaksÚ+StreamContextVariable.supports_graph_breaks  s   € Ør(   c                 óJ   • U R                   (       d   S5       eU R                   $ )Nz,Stream context should have a separate stream©r-   rŒ   s    r&   r©   Ú StreamContextVariable.get_stream  s   € Ø�{�{ÐJÐJÓJˆ{Ø�{‰{Ðr(   r¹   ©r   r+   )r9   r˜   r™   rš   r›   ÚstaticmethodÚdictÚstrr   r}   r   r„   r   r¯   r³   rœ   r¶   r©   r�   Ú__classcell__©r«   s   @r&   rŸ   rŸ   ô   s´   ø† Ù2àð
Ø#ð
à)ð
ð �s˜C�x‘.ð
ð 
!ó	
ó ð
ð
˜xÐ(8Ñ9ð 
ÀSð 
ÈT÷ 
ð!Ø)ð!Ø2Að!à	÷!ð'Ø)ð'Ø2Að'à	÷'ð tô ÷ò r(   rŸ   c                   ó  ^ • \ rS rSrSr SS\S\R                  S\\	   S\
SS4
U 4S	 jjjrS\4S
 jrSSS\S\\   S\\\4   S\4
U 4S jjrS\4S jrS\4S jrS\4S jrSS jrSS jr\S\S\S\\	S/S4   4S j5       rSrU =r$ )r+   i"  z1Represents the device-agnostic torch.Stream classNÚproxyÚvaluerª   r   r   c                 óä   >• Ub9  SUR                   R                  ;   a  UR                   R                  S   U:X  d   eXl        X l        UR                  U l        X0l        [        TU ]  " S0 UD6  g )NÚexample_valuer    )ÚnodeÚmetarÂ   rÃ   r/   rª   r¨   r„   ©r�   rÂ   rÃ   rª   r   r«   s        €r&   r„   ÚStreamVariable.__init__%  s`   ø€ ð Ñ °E·J±J·O±OÓ!CØ—:‘:—?‘? ?Ñ3°uÓ<Ð<Ð<àŒ
ØŒ
à—l‘lˆŒà!2ÔÜ‰ÒÑ( Ó(r(   c                 ó"   • [         R                  $ r    )r!   r*   rŒ   s    r&   Úpython_typeÚStreamVariable.python_type9  s   € Ü�|‰|Ðr(   r¡   r   Únamer   c                 óü  >• [        U R                  U5      (       d
   SU 35       eSSKJnJn  SSKJn  US;   a/  UR                  R                  " SU/U" U /U-   U5      Q76   [        $ US:X  a3  U" [        UUR                  R                  " SU/U" U /U-   U5      Q76 S	9$ US
:X  a3  U" [        UUR                  R                  " SU/U" U /U-   U5      Q76 S	9$ X%;   Ga  [        U5      S:X  aý  U(       dö  SSKJnJn	  U R                   (       a+  U	" U R                   R#                  UR$                  5      5        US   n
['        U
[(        5      (       d  [        R*                  " [,        5      $ U
R                   (       a:  U R                   c   eU	" U R                   R#                  UR$                  5      5        [        R*                  " XR   " U R                  U
R                  5      5      $ [.        TU ]a  XX45      $ )Nzno stream method found named r
   )Úcmp_name_to_op_mappingÚproxy_args_kwargsr   ©Úwrap_fx_proxy_cls)rg   Úsynchronizerb   Úcall_methodÚquery©Ú
target_clsr¡   rÂ   r]   )ÚGuardBuilderÚinstall_guardr   )ÚhasattrrÃ   ÚutilsrÏ   rÐ   ÚbuilderrÒ   ÚoutputÚcreate_proxyr   r   r#   r•   ÚguardsrØ   rÙ   r{   Ú
make_guardÚEQUALS_MATCHrH   r+   r}   ÚNotImplementedr¨   rÔ   )r�   r¡   rÍ   r   r   rÏ   rÐ   rÒ   rØ   rÙ   Úotherr«   s              €r&   rÔ   ÚStreamVariable.call_method<  sÏ  ø€ ô �t—z‘z 4×(Ñ(ÐPÐ,IÈ$ÈÐ*PÓPÐ(çEÝ.àÐ?Ó?Ø�I‰I×"Ò"Ø˜tðÙ&7¸¸À¹ÀvÓ&Nóô *Ð)Ø�W‹_Ù$Ü+ØØ—i‘i×,Ò,Ø! 4ðÙ*;¸T¸FÀT¹MÈ6Ó*Ròñð ð �^Ó#Ù$Ü(ØØ—i‘i×,Ò,Ø! 4ðÙ*;¸T¸FÀT¹MÈ6Ó*Ròñð ð Ô+´°D³	¸Q³Ævß<à�{�{Ù˜dŸk™k×4Ñ4°\×5NÑ5NÓOÔPð ˜‘GˆEÜ˜e¤^×4Ñ4Ü'×.Ò.¬~Ó>Ð>à�|�|Ø—{‘{Ñ.Ð.Ð.Ù˜dŸk™k×4Ñ4°\×5NÑ5NÓOÔPÜ#×*Ò*Ø&Ò,¨T¯Z©Z¸¿¹ÓEóð ô ‰wÑ" 2¨TÓ:Ð:r(   c                 ó   • U R                   $ r    ©rÂ   rŒ   s    r&   Úas_proxyÚStreamVariable.as_proxyr  ó   € Ø�z‰zÐr(   c                 ó   • g)Nztorch._CrL   rŒ   s    r&   Úmodule_nameÚStreamVariable.module_nameu  s   € Ør(   c                 ó   • g)Nr*   rL   rŒ   s    r&   Úfn_nameÚStreamVariable.fn_namex  s   € Ør(   r   c                 ó¶  ^• U R                   (       a   eU R                  b[  TR                  U4S j5        TR                  TR	                  U R                  5      5        TR                  [        SS5      5        g SU R                   3nTR                  R                  R                  X R                  5      nTR                  TR                  USS95        g )Nc                  ól   >• T R                  [        R                  R                  R                  S5      $ )Nr   r5   ©Úcodegens   €r&   r:   Ú,StreamVariable.reconstruct.<locals>.<lambda>�  s&   ø€ ˜×0Ñ0Ü—M‘M×7Ñ7×@Ñ@Ø2ôr(   r   FÚ_stream_T©Úadd)r{   rª   r<   Úappend_outputÚcreate_load_constr=   r   r/   r¡   rÝ   Úinstall_global_by_idrÃ   Úcreate_load_global©r�   ró   ÚprefixrÍ   s    `  r&   ÚreconstructÚStreamVariable.reconstruct{  sµ   ø€ ð —;—;ÐˆØ×!Ñ!Ñ-Ø×!Ñ!ôôð ×!Ñ! '×";Ñ";¸D×<RÑ<RÓ"SÔTØ×!Ñ!Ô"6°q¸%Ó"@ÕAð   §¡˜}Ð-ˆFØ—:‘:×$Ñ$×9Ñ9¸&Ç*Á*ÓMˆDØ×!Ñ! '×"<Ñ"<¸TÀtÐ"<Ð"LÕMr(   c                 ó   • U $ r    rL   rŒ   s    r&   r©   ÚStreamVariable.get_streamŽ  s   € Øˆr(   c                 ó0   ^ ^• S[         SSSS 4U U4S jjnU$ )NrF   ró   r   r   c                 óè   >^• TR                  U4S j5        TR                  U4S j5        T" T5        T" T5        TR                  [        SS5      5        TR                  [        SS5      5        g )Nc                  ól   >• T R                  [        R                  R                  R                  S5      $ r3   r5   rò   s   €r&   r:   ÚNStreamVariable.make_construct_in_graph_stream_fn.<locals>.fn.<locals>.<lambda>—  ó&   ø€ ˜×0Ñ0Ü—M‘M×7Ñ7×@Ñ@Ø0ôr(   c                  ól   >• T R                  [        R                  R                  R                  S5      $ )NÚbuild_stream©r6   r!   r7   rÛ   r9   rò   s   €r&   r:   r  �  s%   ø€ ˜×0Ñ0Ü—M‘M×'Ñ'×0Ñ0°.ôr(   r
   Fr   ©r<   r=   r   ©rF   ró   r   r   s    `€€r&   ÚfnÚ<StreamVariable.make_construct_in_graph_stream_fn.<locals>.fn•  óg   ù€ Ø×!Ñ!ôôð ×!Ñ!ôôñ
 �DŒMÙ�FŒOØ×!Ñ!Ô"6°q¸%Ó"@ÔAØ×!Ñ!Ô"6°q¸%Ó"@ÕAr(   ©Úint©r   r   r  s   `` r&   r,   Ú0StreamVariable.make_construct_in_graph_stream_fn‘  ó.   ù€ ð	B”cð 	B Kð 	B°D÷ 	Bð 	Bð" ˆ	r(   )r/   rÂ   rª   rÃ   r    ©ró   r   r   Nr»   )r9   r˜   r™   rš   r›   r	   r!   r*   r   r  r   r„   ÚtyperË   r¾   Úlistr   r½   rÔ   rç   rë   rî   rþ   r©   r¼   r   r   r   r,   r�   r¿   rÀ   s   @r&   r+   r+   "  s  ø† Ù;ð ,0ñ	)àð)ð �|‰|ð)ð $ C™=ð	)ð
 ð)ð 
÷)ð )ð(˜Tô ð4;à#ð4;ð ð4;ð �?Ñ#ð	4;ð
 �S˜/Ð)Ñ*ð4;ð 
÷4;ðl˜%ô ð˜Sô ð˜ô ôNô&ð ðØðØ%6ðà	�3˜Ð$ dÐ*Ñ	+óó ör(   r+   c            
       ó  ^ • \ rS rSrS\S\R                  S\\   S\	SS4
U 4S jjr
S	S
S\S\\   S\\\4   S\4
S jrS\4S jr\S	S
S\\   S\\\4   SS4S j5       r\S\S\S\\S/S4   4S j5       rSS jrSrU =r$ )r#   i©  rÂ   rÃ   rª   r   r   Nc                 óÂ   >• Ub9  SUR                   R                  ;   a  UR                   R                  S   U:X  d   e[        TU ]  " S0 UD6  Xl        X l        X0l        g )NrÅ   rL   )rÆ   rÇ   r¨   r„   rÂ   rÃ   rª   rÈ   s        €r&   r„   ÚEventVariable.__init__ª  sU   ø€ ð Ñ °E·J±J·O±OÓ!CØ—:‘:—?‘? ?Ñ3°uÓ<Ð<Ð<Ü‰ÒÑ"˜6Ò"ØŒ
ØŒ
Ø!2Õr(   r¡   r   rÍ   r   c                 óª  • SSK Jn  SSKJn  US:X  ap  UR                  R                  S[        R                  R                  R                  U R                  [        R                  XU5      R                  40 5        [        $ US:X  ap  UR                  R                  S[        R                  R                  R                  U R                  [        R                  XU5      R                  40 5        [        $ US:X  a/  UR                  R
                  " S	U/U" U /U-   U5      Q76   [        $ US
:X  a3  U" [        UUR                  R
                  " S	U/U" U /U-   U5      Q76 S9$ [!        U R"                  5      R$                   S[!        U R"                  5      R&                   SU 3n[)        S[+        U5      SU S3/ [,        R.                  QS9  g )Nr
   )rÐ   r   rÑ   ÚwaitÚcall_functionÚrecordrÓ   rÔ   rÕ   rÖ   Ú.zUnsupported event methodz#Dynamo doesn't support tracing the zC method. We currently support wait, record, synchronize, and query.)Úgb_typeÚcontextÚexplanationÚhints)rÛ   rÐ   rÜ   rÒ   rÝ   rÞ   r!   ro   rp   rb   rª   r#   Ú_get_stream_argr   r]   r   r  rÃ   r˜   r™   r   r¾   r   ÚSUPPORTABLE)r�   r¡   rÍ   r   r   rÐ   rÒ   Úmethod_names           r&   rÔ   ÚEventVariable.call_method¸  sÅ  € õ 	.Ý.à�6‹>Ø�I‰I×"Ñ"ØÜ—	‘	×!Ñ!×,Ñ,à×*Ñ*Ü!×1Ñ1°"¸FÓC×UÑUðð ôô *Ð)Ø�XÓØ�I‰I×"Ñ"ØÜ—	‘	×!Ñ!×.Ñ.à×*Ñ*Ü!×1Ñ1°"¸FÓC×UÑUðð ôô *Ð)Ø�]Ó"Ø�I‰I×"Ò"Ø˜tðÙ&7¸¸À¹ÀvÓ&Nóô *Ð)Ø�W‹_Ù$Ü+ØØ—i‘i×,Ò,Ø! 4ðÙ*;¸T¸FÀT¹MÈ6Ó*Ròñð ô ˜Ÿ
™
Ó#×.Ñ.Ð/¨q´°d·j±jÓ1A×1NÑ1NÐ0OÈqÐQUÐPVÐWð ô Ø2Ü˜D›	ØAÀ+Àð OMð NðÜ&×2Ñ2ðór(   c                 ó   • U R                   $ r    ræ   rŒ   s    r&   rç   ÚEventVariable.as_proxyó  ré   r(   r+   c                 ó–   • S nU(       a  US   nOU(       a  UR                  S5      nU(       d  U R                  R                  5       nU$ )Nr   r-   )Úgetr®   r’   )r¡   r   r   Ú
stream_args       r&   r#  ÚEventVariable._get_stream_argö  sC   € ð ˆ
ÞØ˜a™‰JÞØŸ™ HÓ-ˆJæØ×1Ñ1×<Ñ<Ó>ˆJàÐr(   r   c                 ó0   ^ ^• S[         SSSS 4U U4S jjnU$ )NrF   ró   r   r   c                 óè   >^• TR                  U4S j5        TR                  U4S j5        T" T5        T" T5        TR                  [        SS5      5        TR                  [        SS5      5        g )Nc                  ól   >• T R                  [        R                  R                  R                  S5      $ r3   r5   rò   s   €r&   r:   ÚLEventVariable.make_construct_in_graph_event_fn.<locals>.fn.<locals>.<lambda>  r  r(   c                  ól   >• T R                  [        R                  R                  R                  S5      $ )NÚbuild_eventr	  rò   s   €r&   r:   r0    s%   ø€ ˜×0Ñ0Ü—M‘M×'Ñ'×0Ñ0°-ôr(   r
   Fr   r
  r  s    `€€r&   r  Ú:EventVariable.make_construct_in_graph_event_fn.<locals>.fn  r  r(   r  r  s   `` r&   r$   Ú.EventVariable.make_construct_in_graph_event_fn  r  r(   c                 óÊ   • U R                   (       a   eSnUR                  R                  R                  X R                  5      nUR                  UR                  USS95        g )NÚ_eventTrö   )r{   r¡   rÝ   rú   rÃ   rø   rû   rü   s       r&   rþ   ÚEventVariable.reconstruct  sQ   € ð —;—;ÐˆàˆØ�z‰z× Ñ ×5Ñ5°f¿j¹jÓIˆØ×Ñ˜g×8Ñ8¸À4Ð8ÐHÕIr(   )rÂ   rª   rÃ   r  )r9   r˜   r™   rš   r	   r!   r"   r   r  r   r„   r¾   r  r   r½   rÔ   rç   r¼   r#  r   r   r   r$   rþ   r�   r¿   rÀ   s   @r&   r#   r#   ©  s  ø† ð3àð3ð �{‰{ð3ð $ C™=ð	3ð
 ð3ð 
÷3ð9à#ð9ð ð9ð �?Ñ#ð	9ð
 �S˜/Ð)Ñ*ð9ð 
ô9ðv˜%ô ð ðØ#ðà�?Ñ#ðð �S˜/Ð)Ñ*ðð 
ó	ó ðð  ðØðØ%6ðà	�3˜Ð$ dÐ*Ñ	+óó ð÷,Jò Jr(   r#   )Gr~   Úcollections.abcr   Útypingr   r   r!   Útorch._dynamo.variables.dictsr   Útorch._dynamo.variables.listsr   Útorch.fxr   r	   Ú r   Úbytecode_transformationr   Úexcr   r   r8   r   r   r{   r   Úbaser   Úconstantr   r   Úctx_managerr   Úlazyr   Útorch._dynamo.symbolic_convertr   ró   r   Útorch._library.custom_opsr   ÚTensorr  r'   Útupler.   r/   r>   rE   r*   rI   r"   rK   rT   Úregister_fakerA   ro   rp   Úforkrq   rX   Újoinr]   rb   rg   rr   ru   rx   rŸ   r+   r#   rL   r(   r&   Ú<module>rK     s©  ðÛ Ý $ß  ã Ý ;Ý 7ß +å  Ý :ß .÷õ )Ý !ß >Ý 4Ý %ö ÝDå#å /ð 
�‰€ð�Sð  Cð ¨Cô ð�e˜C‘jð ¨Cð °Cô ð5 E§L¡Lð 5°kð 5Àdô 5ð˜uŸ|™|ð °ô ð ð ¨¯©ô ð˜sð  u§{¡{ô ñ ˆ?¨Ñ,ðAØðAàðAð 
óAó -ðAð ×Ñð	Øð	àð	ð 
ó	ó ð	ñ �—	‘	×!Ñ!×&Ñ&×.Ñ.Ô /ñ ˆ?¨Ñ,ðA˜Cð A¨3ð A°4ó Aó -ðAð ×Ñð	Øð	àð	ð 
ó	ó ð	ñ �—	‘	×!Ñ!×&Ñ&×.Ñ.Ô /ñ Ð"°Ñ4ð˜cð °ð ¸ó ó 5ðð ×Ñð	Øð	àð	ð 
ó	ó ð	ñ �—	‘	×!Ñ!×.Ñ.×6Ñ6Ô 7ñ Ð ¨rÑ2ð˜Cð ¨sð °tó ó 3ðð ×Ñð	Øð	àð	ð 
ó	ó ð	ñ �—	‘	×!Ñ!×,Ñ,×4Ñ4Ô 5ñ Ð!°Ñ3ð# cð #À3ð #È4ó #ó 4ð#ð ×Ñð	Øð	àð	ð 
ó	ó ð	ñ �—	‘	×!Ñ!×-Ñ-×5Ñ5Ô 6ñ Ð"°Ñ4ð	MØð	MØ-0ð	MØ>C¿l¹lð	Mà	ó	Mó 5ð	Mñ �—	‘	×!Ñ!×.Ñ.×6Ñ6Ô 7ñ Ð#°"Ñ5ð=˜%Ÿ,™,ð =°cð =¸dó =ó 6ð=ð ×Ñð	Øð	àð	ð —‘ð	ð 
ó		ó ð	÷!.ñ !.ôH+Ð7ô +ô\DÐ*ô DôN|J�Oõ |Jr(   