+
    ˜°³j-  ã                   óf  € ^ RI t ^ RIHt ^ RIHt ^ RIHt ^ RIH	t	H
t
 . ROt]! R4       ! R R]
4      4       t]! RRR7       ! R R
]	4      4       t]! RRR7       ! R R]	4      4       t]! RRR7       ! R R]	4      4       t]! RRR7       ! R R	]	4      4       t]! RRR7       ! R R]	4      4       tR# )é    N)ÚAny)Úfunctional_datapipe)Údataframe_wrapper)ÚDFIterDataPipeÚIterDataPipeÚConcatDataFramesPipeÚDataFramesAsTuplesPipeÚExampleAggregateAsDataFramesÚFilterDataFramesPipeÚPerRowDataFramesPipeÚShuffleDataFramesPipeÚ_dataframes_as_tuplesc                   óD   a a€ ] tR t^t oV3R lV 3R lltR tRtVtV ;t# )r	   c                ó   <€ V ^8„  d   QhRR/# ©é   ÚreturnN© )ÚformatÚ__classdict__s   "€Úo/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/utils/data/datapipes/dataframe/datapipes.pyÚ__annotate__Ú#DataFramesAsTuplesPipe.__annotate__   s   ø€ ÷ /ñ /¨4ñ /ó    c                ó0   <€ \         SV `  4        Wn        R # ©N)ÚsuperÚ__init__Úsource_datapipe)Úselfr   Ú	__class__s   &&€r   r   ÚDataFramesAsTuplesPipe.__init__   s   ø€ Ü‰ÑÔØ.Ör   c              #  ót   "  € V P                    F!  p\        P                  ! V4       R j  x€L
  K#  	  R #  L
5ir   )r   Ú
df_wrapperÚiterate)r    Údfs   & r   Ú__iter__ÚDataFramesAsTuplesPipe.__iter__   s,   é € Ø×&Ô&ˆBä!×)Ò)¨"Ó-×-Ò-ó 'á-ùs   ‚)8«6¬8©r   )	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r'   Ú__static_attributes__Ú__classdictcell__Ú__classcell__)r!   r   s   @@r   r	   r	      s   ù‡ € ÷/ó /÷.ò .r   Ú_dataframes_per_rowT)Úenable_df_api_tracingc                   ó8   a € ] tR t^ t o V 3R lR ltR tRtV tR# )r   c                ó   <€ V ^8„  d   QhRR/# r   r   )r   r   s   "€r   r   Ú!PerRowDataFramesPipe.__annotate__"   ó   ø€ ÷ /ñ /¨4ñ /r   c                ó   € Wn         R # r   r)   ©r    r   s   &&r   r   ÚPerRowDataFramesPipe.__init__"   ó   € Ø.Ör   c              #  ó„   "  € V P                    F+  p\        \        V4      4       F  pWV^,            x € K  	  K-  	  R# 5i)é   N)r   ÚrangeÚlen)r    r&   Úis   &  r   r'   ÚPerRowDataFramesPipe.__iter__%   s5   é € Ø×&Ô&ˆBäœ3˜r›7–^�Ø˜Q �U�mÔ#ó $ó 'ùs   ‚>A r)   N©r*   r+   r,   r-   r   r'   r.   r/   ©r   s   @r   r   r       s   ø‡ € ÷/ð /÷$ð $r   Ú_dataframes_concatc                   ó<   a € ] tR t^,t o RV 3R lR lltR tRtV tR# )r   c                ó   <€ V ^8„  d   QhRR/# r   r   )r   r   s   "€r   r   Ú!ConcatDataFramesPipe.__annotate__.   s   ø€ ÷ ñ °Dñ r   c                ó   € Wn         W n        R # r   )r   Ún_batch)r    r   Úbatchs   &&&r   r   ÚConcatDataFramesPipe.__init__.   s   € Ø.ÔØŽr   c              #  ó
  "  € . pV P                    FJ  pVP                  V4       \        V4      V P                  8X  g   K0  \        P
                  ! V4      x € . pKL  	  V'       d   \        P
                  ! V4      x € R # R # 5ir   )r   Úappendr>   rH   r$   Úconcat)r    Úbufferr&   s   &  r   r'   ÚConcatDataFramesPipe.__iter__2   sg   é € ØˆØ×&Ô&ˆBØ�M‰M˜"ÔÜ�6‹{˜dŸl™lÖ*Ü ×'Ò'¨Ó/Ò/Ø’ñ	 '÷
 Ü×#Ò# FÓ+Ô+ñ ùs   ‚:BÁ%BÁ'B)rH   r   N)é   rA   rB   s   @r   r   r   ,   s   ø‡ € ÷ò ÷,ð ,r   Ú_dataframes_shufflec                   ó8   a € ] tR t^=t o V 3R lR ltR tRtV tR# )r   c                ó   <€ V ^8„  d   QhRR/# r   r   )r   r   s   "€r   r   Ú"ShuffleDataFramesPipe.__annotate__?   r6   r   c                ó   € Wn         R # r   r)   r8   s   &&r   r   ÚShuffleDataFramesPipe.__init__?   r:   r   c           	   #  óâ  a"  € R p. pV P                    FU  oVf   \        P                  ! S4      pVP                  V3R l\	        \        P                  ! S4      4       4       4       KW  	  \
        P                  ! V4       . pV F@  oVP                  S4       \        V4      V8X  g   K&  \        P                  ! V4      x € . pKB  	  V'       d   \        P                  ! V4      x € R # R # 5i)Nc              3   óR   <"  € T F  p\         P                  ! SV4      x € K  	  R # 5ir   )r$   Úget_item)Ú.0r?   r&   s   & €r   Ú	<genexpr>Ú1ShuffleDataFramesPipe.__iter__.<locals>.<genexpr>H   s%   øé € ð Ù4Q¨q”
×#Ò# B¨×*Ð*Ó4Qùs   ƒ$')
r   r$   Úget_lenÚextendr=   ÚrandomÚshufflerL   r>   rM   )r    ÚsizeÚ
all_bufferrN   r&   s   &   @r   r'   ÚShuffleDataFramesPipe.__iter__B   sÆ   øé € ØˆØ "ˆ
Ø×&Ô&ˆBØŠ|Ü!×)Ò)¨"Ó-�Ø×Ñô Ü49¼*×:LÒ:LÈRÓ:PÔ4Qóö ñ 'ô 	�Š�zÔ"ØˆÛˆBØ�M‰M˜"ÔÜ�6‹{˜dÖ"Ü ×'Ò'¨Ó/Ò/Ø’ñ	 ÷
 Ü×#Ò# FÓ+Ô+ñ ùs   ƒB%C/Â-%C/ÃC/r)   NrA   rB   s   @r   r   r   =   s   ø‡ € ÷/ð /÷,ð ,r   Ú_dataframes_filterc                   ó8   a € ] tR t^Vt o V 3R lR ltR tRtV tR# )r   c                ó   <€ V ^8„  d   QhRR/# r   r   )r   r   s   "€r   r   Ú!FilterDataFramesPipe.__annotate__X   s   ø€ ÷ #ñ #°dñ #r   c                ó   € Wn         W n        R # r   )r   Ú	filter_fn)r    r   ri   s   &&&r   r   ÚFilterDataFramesPipe.__init__X   s   € Ø.ÔØ"Žr   c              #  óT  "  € R p. p. pV P                    FŒ  pVf   \        VP                  4      p\        \        VP                  4      4       FN  pVP	                  WEV^,            4       VP	                  V P                  VP                  V,          4      4       KP  	  KŽ  	  . p\        W#RR7       FL  w  rGV'       g   K  VP	                  V4       \        V4      V8X  g   K2  \        P                  ! V4      x € . pKN  	  V'       d   \        P                  ! V4      x € R # R # 5i)NT)Ústrict)
r   r>   Úindexr=   rL   ri   ÚilocÚzipr$   rM   )r    ra   rb   Ú
filter_resr&   r?   rN   Úress   &       r   r'   ÚFilterDataFramesPipe.__iter__\   së   é € ØˆØˆ
Øˆ
à×&Ô&ˆBØŠ|Ü˜2Ÿ8™8“}�Üœ3˜rŸx™x›=Ö)�Ø×!Ñ! "¨¨Q­ -Ô0Ø×!Ñ! $§.¡.°·±¸µÓ"<Ö=ó *ñ 'ð ˆÜ˜:¸$×?‰GˆBß‰sØ—‘˜bÔ!Ü�v“; $Ö&Ü$×+Ò+¨FÓ3Ò3Ø’Fñ @÷ Ü×#Ò# FÓ+Ô+ñ ùs   ‚B<D(ÃD(Ã&%D(ÄD()ri   r   NrA   rB   s   @r   r   r   V   s   ø‡ € ÷#ð #÷,ð ,r   Ú_to_dataframes_pipec                   óB   a € ] tR t^st o RV 3R lR lltR tR tRtV tR# )r
   Nc                ó   <€ V ^8„  d   QhRR/# r   r   )r   r   s   "€r   r   Ú)ExampleAggregateAsDataFrames.__annotate__u   s   ø€ ÷ -ñ -ÈDñ -r   c                ó*   € Wn         W0n        W n        R # r   )r   ÚcolumnsÚdataframe_size)r    r   ry   rx   s   &&&&r   r   Ú%ExampleAggregateAsDataFrames.__init__u   s   € Ø.ÔØŒØ,Ör   c                óB   €  \        V4      #   \         d    T.u # i ; ir   )ÚlistÚ	Exception)r    Úitems   &&r   Ú_as_listÚ%ExampleAggregateAsDataFrames._as_listz   s)   € ð	Ü˜“:Ðøäô	ð �6ŠMð	ús   ‚
 ��c              #  ód  "  € . pV P                    Fd  pVP                  V P                  V4      4       \        V4      V P                  8X  g   K?  \
        P                  ! WP                  R 7      x € . pKf  	  \        V4      ^ 8”  d&   \
        P                  ! WP                  R 7      x € R# R# 5i))rx   N)r   rL   r   r>   ry   r$   Úcreate_dataframerx   )r    Ú	aggregater~   s   &  r   r'   Ú%ExampleAggregateAsDataFrames.__iter__‚   s…   é € Øˆ	Ø×(Ô(ˆDØ×Ñ˜TŸ]™]¨4Ó0Ô1Ü�9‹~ ×!4Ñ!4Ö4Ü ×1Ò1°)Ç\Á\ÔRÒRØ’	ñ	 )ô
 ˆy‹>˜AÔÜ×-Ò-¨iÇÁÔNÔNñ ùs   ‚A	B0ÁA B0)rx   ry   r   )é
   N)	r*   r+   r,   r-   r   r   r'   r.   r/   rB   s   @r   r
   r
   s   s    ø‡ € ÷-ò -ò
÷Oð Or   )r   r	   r
   r   r   r   )r_   Útypingr   Ú%torch.utils.data.datapipes._decoratorr   Ú$torch.utils.data.datapipes.dataframer   r$   Ú#torch.utils.data.datapipes.datapiper   r   Ú__all__r	   r   r   r   r   r
   r   r   r   Ú<module>r‹      só   ðã Ý å EÝ Pß Lò€ñ Ð,Ó-ô.˜\ó .ó .ð.ñ Ð*À$ÔGô$˜>ó $ó Hð$ñ Ð)ÀÔFô,˜>ó ,ó Gð,ñ  Ð*À$ÔGô,˜Nó ,ó Hð,ñ0 Ð)ÀÔFô,˜>ó ,ó Gð,ñ8 Ð*À$ÔGôO >ó Oó HòOr   