
    sh4                        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Qr
S r " S S5      r " S	 S
\5      r/ SQr/ SQr " S S5      r " S S\5      r " S S\5      r " S S5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S \5      r " S! S"\5      r " S# S$\5      r " S% S&\5      rS' r " S( S)\5      r " S* S+\5      r " S, S-\5      r \" S.5       " S/ S0\ \	5      5       r!g1)2    )AnyOptional)functional_datapipe)DataChunkDF)DFIterDataPipeIterDataPipe)CaptureCaptureA
CaptureAddCaptureCallCaptureControlCaptureDataFrameCaptureDataFrameWithDataPipeOpsCaptureFCaptureGetAttrCaptureGetItemCaptureInitialCaptureLikeMock
CaptureMulCaptureSetItem
CaptureSubCaptureVariableCaptureVariableAssignDataFrameTracerDataFrameTracedOpsdisable_captureget_valc                      S[         l        g )NT)r   disabled     ڃ/Users/tiagomarins/Projetos/claudeai/copy_bank/venv/lib/python3.13/site-packages/torch/utils/data/datapipes/dataframe/dataframes.pyr   r   $   s
    "Nr!   c                       \ rS rSrSrSrg)r   (   Fr    N)__name__
__module____qualname____firstlineno__r   __static_attributes__r    r!   r"   r   r   (   s    Hr!   r   c                        \ rS rSrS rS rSrg)r   ,   c                     Xl         X l        g N)source_datapipe
output_var)selfr.   r/   s      r"   __init__DataFrameTracedOps.__init__-   s    .$r!   c              #   l   #    U R                    H   nU R                  R                  U5      v   M"     g 7fr-   )r.   r/   	apply_ops)r0   items     r"   __iter__DataFrameTracedOps.__iter__1   s*     ((D//++D11 )s   24)r/   r.   N)r%   r&   r'   r(   r1   r6   r)   r    r!   r"   r   r   ,   s    %2r!   r   )_dataframes_as_tuplesgroupby_dataframes_filtermapto_datapipeshuffleconcatbatch_dataframes_per_row_dataframes_concat_dataframes_shuffle)__deepcopy____setstate__is_shardableapply_shardingc                   |    \ rS rSrSS jrS rS rS rS rS r	S	 r
S
 rS rS rS rS rS r\S 5       rS rSrg)r	   H   Nc                     / / US.U l         g )N
operations	variables	schema_dfctx)r0   rM   s     r"   r1   Capture.__init__K   s    "$2INr!   c                 "    U R                  5       $ r-   )_ops_strr0   s    r"   __str__Capture.__str__N   s    }}r!   c                 z    SnU R                   S    H%  n[        U5      S:  a  US-  nU[        U5      -  nM'     U$ )N rK   r   
)rO   lenstr)r0   resops      r"   rR   Capture._ops_strQ   sB    ((<(B3x!|t3r7NC ) 
r!   c                     S U R                   S'   U R                   S    H
  nS Ul        M     0 nU R                   H  n[        X5      X#'   M     U$ )NrM   rL   )rO   calculated_value__dict__getattr)r0   varstater5   s       r"   __getstate__Capture.__getstate__Y   sO     $88K(C#'C  )MMD!$-EK "r!   c                 N    UR                  5        H  u  p#[        XU5        M     g r-   )itemssetattr)r0   rc   kvs       r"   rD   Capture.__setstate__c   s    KKMDADQ "r!   c                 t    US:X  d  US:X  a  [        S5      eUS;   a  [        e[        XU R                  S9nU$ )Nkwargkwargsz
no kwargs!)rC   rN   )RuntimeErrorAttributeErrorr   rO   )r0   attrnameresults      r"   __getattr__Capture.__getattr__g   s@    w(h"6|,,''  DHH=r!   c                 *    [        XU R                  S9$ )NrN   )r   rO   )r0   keys     r"   __getitem__Capture.__getitem__o   s    dTXX66r!   c           	      d    U R                   S   R                  [        XX R                   S95        g )NrK   rN   )rO   appendr   )r0   rv   values      r"   __setitem__Capture.__setitem__r   s$    %%nT88&TUr!   c                     [        XU R                  S9n[        X R                  S9nU R                  S   R                  [	        X2U R                  S95        U$ NrN   rK   variabler{   rO   )r   rO   r   rz   r   r0   add_valr[   rb   s       r"   __add__Capture.__add__u   L    DHH5cxx0%%!3txxH	
 
r!   c                     [        XU R                  S9n[        X R                  S9nU R                  S   R                  [	        X2U R                  S95        U$ r   )r   rO   r   rz   r   r   s       r"   __sub__Capture.__sub__}   r   r!   c                     [        XU R                  S9n[        X R                  S9n[        X2U R                  S9nU R                  S   R	                  U5        U$ )NrN   r   rK   )r   rO   r   r   rz   )r0   r   r[   rb   ts        r"   __mul__Capture.__mul__   sL    DHH5cxx0!3txxH%%a(
r!   c                 |    [        U R                  S   5      S:H  =(       a    [        U R                  S   5      S:H  $ )NrK   r   rL   )rY   rO   rS   s    r"   _is_context_emptyCapture._is_context_empty   s4    488L)*a/SC8M4NRS4SSr!   c                 |    XR                   S   S   l        U R                   S    H  nUR                  5         M     g NrL   r   rK   rO   r_   executer0   	dataframer\   s      r"   apply_ops_2Capture.apply_ops_2   s2    4=a 1((<(BJJL )r!   c                 v    U R                  U R                  S   5        U R                  5       nUR                  $ )NrM   )r   rO   r   columnsr0   r{   s     r"   r   Capture.columns   s.    +./}}r!   c                    U R                  5       (       a  U HB  n[        U[        5      (       d  M  UR                  5       (       a  M1  UR                  U l          O   U R                  5       (       a  UR	                  5        H  u  pE[        U[        5      (       a(  UR                  5       (       d  UR                  U l          OC[        U[        5      (       d  MY  UR                  5       (       a  Mp  UR                  U l          O   [        X R                  XS9n[        S U R                  S9n[        U R                  XvS9nU R                  S   R                  U5        U$ )N)rO   argsrn   rN   )rO   r   r{   rK   )	r   
isinstancer	   rO   rg   r   r   r   rz   )	r0   r   rn   argri   rj   r[   rb   r   s	            r"   __call__Capture.__call__   s   !!##c7++C4I4I4K4K"wwDH  %%''"LLNDA!!W--a6I6I6K6K#$55!!W--a6I6I6K6K#$55 + $HH4Gd1!dhhH%%a(
r!   rN   r-   )r%   r&   r'   r(   r1   rT   rR   rd   rD   rs   rw   r|   r   r   r   r   r   propertyr   r   r)   r    r!   r"   r	   r	   H   s_    O 7VT  r!   r	   c                       \ rS rSrSS jrSrg)r      Nc                 8    Uc  / / S.U l         OXl         X l        g N)rK   rL   rO   rn   )r0   rO   rn   s      r"   r1   CaptureF.__init__   s    ;&(r:DHHr!   r   r-   )r%   r&   r'   r(   r1   r)   r    r!   r"   r   r      s    r!   r   c                        \ rS rSrS rS rSrg)r
      c                 "    U R                   S    $ )Nnamern   rS   s    r"   rT   CaptureA.__str__   s    ++f%&'r!   c                 $    U R                   S   nU$ )Nreal_attributer   r   s     r"   r   CaptureA.execute   s    ,-r!   r    Nr%   r&   r'   r(   rT   r   r)   r    r!   r"   r
   r
      s    (r!   r
   c                   &    \ rS rSrS rS rS rSrg)r      c                 Z    SS K Jn  UR                  U5      u  p4X0l        X@l        Xl        g )Nr   )unittest.mockmock_get_target
get_target	attributer   )r0   r   r   r   r   s        r"   r1   CaptureLikeMock.__init__   s)    $ !% 0 0 6
$"	r!   c                     [        U R                  5       U R                  5      U l        [	        U R
                  U R                  S9n[        U R                  5       U R                  U5        g )N)r   r   )ra   r   r   saver
   r   rh   )r0   capts     r"   	__enter__CaptureLikeMock.__enter__   sF    DOO-t~~>	TYYtyyA!4>>48r!   c                 b    [        U R                  5       U R                  U R                  5        g r-   )rh   r   r   r   )r0   exc_infos     r"   __exit__CaptureLikeMock.__exit__   s    !4>>499=r!   )r   r   r   r   N)r%   r&   r'   r(   r1   r   r   r)   r    r!   r"   r   r      s    9
>r!   r   c                   *    \ rS rSrSS jrS rS rSrg)r      Nc                 D    Uc  / / S.U l         OX l         X0l        Xl        g r   )rO   rn   callable)r0   r   rO   rn   s       r"   r1   CaptureCall.__init__   s"    ;&(r:DHH r!   c                 R    SR                   " SSU R                  0U R                  D6$ )Nz{callable}({args},{kwargs})r   r    )formatr   rn   rS   s    r"   rT   CaptureCall.__str__   s-    ,33 
]]
&*kk
 	
r!   c                    / nU R                   S    HJ  n[        U[        5      (       a!  UR                  UR	                  5       5        M9  UR                  U5        ML     [        U R                  5      nU" U0 U R                   S   D6$ )Nr   rn   )rn   r   r	   rz   r   r   r   )r0   executed_argsr   lefts       r"   r   CaptureCall.execute   sr    ;;v&C#w''$$S[[]3$$S)	 '
 t}}%]<dkk(&;<<r!   )r   rO   rn   r-   r%   r&   r'   r(   r1   rT   r   r)   r    r!   r"   r   r      s    !

	=r!   r   c                        \ rS rSrS rS rSrg)r      c                 L    U R                   S   nU R                   S   nU SU 3$ )Nr   r{   z = r   )r0   r   r{   s      r"   rT   CaptureVariableAssign.__str__   s/    ;;z*G$3ug&&r!   c                 b    U R                   S   R                  5       U R                   S   l        g )Nr{   r   )rn   r   r_   rS   s    r"   r   CaptureVariableAssign.execute   s%    37;;w3G3O3O3QJ0r!   r    Nr   r    r!   r"   r   r      s    '
Rr!   r   c                   0    \ rS rSrSrS rS rS rS rSr	g)	r      r   c                     [         R                  (       a  [        S5      eX l        Xl        S[
        R                   3U l        [
        =R                  S-  sl        U R                  S   R                  U 5        g )Nz6Attempting to create capture variable with capture offvar_   rL   )	r   r   ro   rO   r{   r   	names_idxr   rz   )r0   r{   rO   s      r"   r1   CaptureVariable.__init__  s^    ""WXX
?4456	!!Q&!$$T*r!   c                     U R                   $ r-   r   rS   s    r"   rT   CaptureVariable.__str__  s    yyr!   c                     U R                   $ r-   )r_   rS   s    r"   r   CaptureVariable.execute  s    $$$r!   c                     XR                   S   S   l        U R                   S    H  nUR                  5         M     U R                  $ r   r   r   s      r"   r4   CaptureVariable.apply_ops  s>    4=a 1((<(BJJL )$$$r!   )rO   r   r{   N)
r%   r&   r'   r(   r   r1   rT   r   r4   r)   r    r!   r"   r   r      s    I+%%r!   r   c                   &    \ rS rSrS rS rS rSrg)r   i  c                 (    X0l         Xl        X l        g r-   )rO   r   rv   )r0   r   rv   rO   s       r"   r1   CaptureGetItem.__init__  s    	r!   c                 L    U R                    S[        U R                  5       S3$ )N[])r   r   rv   rS   s    r"   rT   CaptureGetItem.__str__   s#    ))Agdhh/022r!   c                 R    U R                   R                  5       nXR                     $ r-   )r   r   rv   )r0   r   s     r"   r   CaptureGetItem.execute#  s     yy  "HH~r!   )rO   rv   r   Nr   r    r!   r"   r   r     s    
3r!   r   c                   &    \ rS rSrS rS rS rSrg)r   i(  c                 4    X@l         Xl        X l        X0l        g r-   )rO   r   rv   r{   )r0   r   rv   r{   rO   s        r"   r1   CaptureSetItem.__init__)  s    	
r!   c                 d    U R                    S[        U R                  5       SU R                   3$ )Nr   z] = )r   r   rv   r{   rS   s    r"   rT   CaptureSetItem.__str__/  s+    ))Agdhh/0TZZLAAr!   c                     U R                   R                  5       nU R                  R                  5       nX!U R                  '   g r-   )r   r   r{   rv   )r0   r   r{   s      r"   r   CaptureSetItem.execute2  s1    yy  "

""$TXXr!   )rO   rv   r   r{   Nr   r    r!   r"   r   r   (  s    Br!   r   c                   &    \ rS rSrS rS rS rSrg)r   i8  c                 (    X0l         Xl        X l        g r-   rO   r   rightr0   r   r   rO   s       r"   r1   CaptureAdd.__init__9      	
r!   c                 8    U R                    SU R                   3$ )Nz + r   r   rS   s    r"   rT   CaptureAdd.__str__>      ))C

|,,r!   c                 X    [        U R                  5      [        U R                  5      -   $ r-   r   r   r   rS   s    r"   r   CaptureAdd.executeA      tyy!GDJJ$777r!   r   Nr   r    r!   r"   r   r   8      
-8r!   r   c                   &    \ rS rSrS rS rS rSrg)r   iE  c                 (    X0l         Xl        X l        g r-   r   r   s       r"   r1   CaptureMul.__init__F  r   r!   c                 8    U R                    SU R                   3$ )Nz * r   rS   s    r"   rT   CaptureMul.__str__K  r  r!   c                 X    [        U R                  5      [        U R                  5      -  $ r-   r  rS   s    r"   r   CaptureMul.executeN  r  r!   r   Nr   r    r!   r"   r   r   E  r  r!   r   c                   &    \ rS rSrS rS rS rSrg)r   iR  c                 (    X0l         Xl        X l        g r-   r   r   s       r"   r1   CaptureSub.__init__S  r   r!   c                 8    U R                    SU R                   3$ )Nz - r   rS   s    r"   rT   CaptureSub.__str__X  r  r!   c                 X    [        U R                  5      [        U R                  5      -
  $ r-   r  rS   s    r"   r   CaptureSub.execute[  r  r!   r   Nr   r    r!   r"   r   r   R  r  r!   r   c                   &    \ rS rSrS rS rS rSrg)r   i_  c                 (    X0l         Xl        X l        g r-   )rO   srcr   )r0   r  r   rO   s       r"   r1   CaptureGetAttr.__init__`  s    	r!   c                 8    U R                    SU R                   3$ )N.)r  r   rS   s    r"   rT   CaptureGetAttr.__str__e  s    ((1TYYK((r!   c                 V    [        U R                  5      n[        XR                  5      $ r-   )r   r  ra   r   )r0   vals     r"   r   CaptureGetAttr.executeh  s    dhhsII&&r!   )rO   r   r  Nr   r    r!   r"   r   r   _  s    
)'r!   r   c                     [        U [        5      (       a  U R                  5       $ [        U [        5      (       a  SU  S3$ U $ )N")r   r	   r   rZ   )captures    r"   r   r   m  s<    '7##  	GS	!	!7)1~r!   c                   ,   ^  \ rS rSrSU 4S jjrSrU =r$ )r   iv  c                 Z   > / / US.n[         TU ]  S U5        SU R                   3U l        g )NrJ   input_)superr1   r   )r0   rM   new_ctx	__class__s      r"   r1   CaptureInitial.__init__w  s6    ")

 	w'TYYK(	r!   r   r-   )r%   r&   r'   r(   r1   r)   __classcell__r'  s   @r"   r   r   v  s    ) )r!   r   c                       \ rS rSrSrg)r   i  r    N)r%   r&   r'   r(   r)   r    r!   r"   r   r     s    r!   r   c                   x   ^  \ rS rSrS rS rS rSS\4S\4S jjr	S	S
S
SS.S jr
S rS rS rU 4S jrSrU =r$ )r   i  c                 N    [        U R                  S   S   R                  U 5      $ )NrL   r   )r   rO   r.   rS   s    r"   as_datapipe+CaptureDataFrameWithDataPipeOps.as_datapipe  s#    !$((;"7":"J"JDQQr!   c                 >    U R                  5       R                  5       $ r-   )r.  r6   rS   s    r"   raw_iterator,CaptureDataFrameWithDataPipeOps.raw_iterator  s    !**,,r!   c                 4    [        U R                  5       5      $ r-   )iterr8   rS   s    r"   r6   (CaptureDataFrameWithDataPipeOps.__iter__  s    D..011r!   
   F	drop_lastc                     U R                  5       R                  U5      nUR                  5       R                  SX#S9nSUl        U$ )Nr   )r7  wrapper_classT)r@   rA   r.  r?   _dp_contains_dataframe)r0   
batch_sizer7  r9  dps        r"   r?   %CaptureDataFrameWithDataPipeOps.batch  sD    %%':::F^^##A#X$(!	r!   i'  Nbuffer_size
group_sizeguaranteed_group_sizedrop_remainingc                h    U R                  5       nUR                  5       R                  UUUUUS9nU$ )Nr>  )r@   r.  r9   )r0   group_key_fnr?  r@  rA  rB  r<  s          r"   r9   'CaptureDataFrameWithDataPipeOps.groupby  sD     %%'^^%%#!"7) & 
 	r!   c                 &    U R                   " U0 UD6$ r-   )rB   r0   r   rn   s      r"   r=   'CaptureDataFrameWithDataPipeOps.shuffle  s    ''888r!   c                 &    U R                   " U0 UD6$ r-   )r:   rG  s      r"   filter&CaptureDataFrameWithDataPipeOps.filter  s    &&777r!   c                     [        S5      e)Nz)Can't collate unbatched DataFrames stream)ro   rG  s      r"   collate'CaptureDataFrameWithDataPipeOps.collate  s    FGGr!   c                    > U[         ;   a  [        SU5      eU[        ;   a  U R                  5       R	                  U5      $ [
        TU ]  U5      $ )NzAttempting to get )UNIMPLEMENTED_ATTRrp   DATAPIPES_OPSr.  rs   r%  )r0   rq   r'  s     r"   rs   +CaptureDataFrameWithDataPipeOps.__getattr__  sL    )) !5x@@}$$$&33H==w"8,,r!   r    )r%   r&   r'   r(   r.  r1  r6   r   boolr?   r9   r=   rJ  rM  rs   r)   r)  r*  s   @r"   r   r     sU    R-2  "U+ d  "&98H- -r!   r   trace_as_dataframec                   N   ^  \ rS rSr% Sr\\   \S'   S rS r	SU 4S jjr
SrU =r$ )	r   i  Nr.   c                     g r-   r    rG  s      r"   set_shuffle_settings$DataFrameTracer.set_shuffle_settings  s    r!   c                     g)NFr    rS   s    r"   rE   DataFrameTracer.is_shardable  s    r!   c                 n   > Xl         Uc  [        [        U R                   5      5      n[        TU ]  US9  g )N)rM   )r.   nextr4  r%  r1   )r0   r.   rM   r'  s      r"   r1   DataFrameTracer.__init__  s4    .T$"6"678I9-r!   )r.   r-   )r%   r&   r'   r(   r.   r   r   __annotations__rW  rE   r1   r)   r)  r*  s   @r"   r   r     s%    %)OXc]). .r!   r   N)"typingr   r   %torch.utils.data.datapipes._decoratorr   /torch.utils.data.datapipes.dataframe.structuresr   #torch.utils.data.datapipes.datapiper   r   __all__r   r   r   rQ  rP  r	   r   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r    r!   r"   <module>rd     s/     E G L
2# 2 2 X k k\w x > >&=' =4RH R%g %6W W  
8 
8
8 
8
8 
8'W ')_ )	~ 	1-&6 1-h )*.5| . +.r!   