+
    QV-jN  ã                   ó´   € ^ RI t ^ RIt^ RIHtHtHt ^ RIt^RIHtH	t	H
t
Ht ^RIHt ^RIHt ^RIHt ^RIHtHt ^RIHt  ! R	 R
]4      t ! R R4      tR# )é    N)ÚBinaryIOÚOptionalÚUnion)ÚDatasetÚFeaturesÚ
NamedSplitÚconfig)Úquery_table)ÚCsv)Útqdm)ÚNestedDataStructureLikeÚPathLike)ÚAbstractDatasetReaderc                   óH   a a€ ] tR t^t oRV3R lV 3R llltR tRtVtV ;t# )ÚCsvDatasetReaderc                ó„   <€ V ^8„  d   QhRS[ S[,          RS[S[,          RS[S[,          RS[RS[RS[RS[S[,          /# )é   Úpath_or_pathsÚsplitÚfeaturesÚ	cache_dirÚkeep_in_memoryÚ	streamingÚnum_proc)r   r   r   r   r   ÚstrÚboolÚint)ÚformatÚ__classdict__s   "€Ú`/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/datasets/io/csv.pyÚ__annotate__ÚCsvDatasetReader.__annotate__   sd   ø€ ÷ 
ñ 
á.©xÕ8ð
ñ ™
Õ#ð
ñ ™8Õ$ð	
ñ
 ð
ñ ð
ñ ð
ñ ™3•-ñ
ó    c                óº   <€ \         S	V `  ! V3R VRVRVRVRVRV/VB  \        V\        4      '       d   TMV P                  V/p\        RRVRVRV/VB V n        R# )	r   r   r   r   r   r   Ú
data_filesN© )ÚsuperÚ__init__Ú
isinstanceÚdictr   r   Úbuilder)
Úselfr   r   r   r   r   r   r   ÚkwargsÚ	__class__s
   &&&&&&&&,€r    r(   ÚCsvDatasetReader.__init__   s¨   ø€ ô 	‰ÒØñ		
àð		
ð ð		
ð  ð			
ð
 *ð		
ð  ð		
ð ð		
ð ò		
ô *4°MÄ4×)HÒ)H™ÈtÏzÉzÐ[hÐNiˆÜñ 
Øð
à$ð
ð ð
ð ñ	
ˆŽr#   c                ó@  € V P                   '       d)   V P                  P                  V P                  R 7      pV# RpRpRpRpV P                  P	                  VVVVV P
                  R7       V P                  P                  V P                  V P                  R7      pV# ))r   N)Údownload_configÚdownload_modeÚverification_modeÚ	base_pathr   )r   Ú	in_memory)r   r+   Úas_streaming_datasetr   Údownload_and_preparer   Ú
as_datasetr   )r,   Údatasetr1   r2   r3   r4   s   &     r    ÚreadÚCsvDatasetReader.read-   s˜   € à�>�>ˆ>Ø—l‘l×7Ñ7¸d¿j¹jÐ7ÓIˆGð  ˆð #ˆOØ ˆMØ $ÐØˆIà�L‰L×-Ñ-Ø /Ø+Ø"3Ø#ØŸ™ð .ô ð —l‘l×-Ñ-°D·J±JÈ$×J]ÑJ]Ð-Ó^ˆGØˆr#   )r+   )NNNFFN)	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r(   r:   Ú__static_attributes__Ú__classdictcell__Ú__classcell__)r.   r   s   @@r    r   r      s   ù‡ € ÷
õ 
÷:ò r#   r   c                   ó`   a € ] tR t^Ct o R
V 3R lR lltV 3R lR ltR tV 3R lR ltR	tV t	R# )ÚCsvDatasetWriterNc                ó~   <€ V ^8„  d   QhRS[ RS[S[S[3,          RS[S[,          RS[S[,          RS[S[,          /# )r   r9   Úpath_or_bufÚ
batch_sizer   Ústorage_options)r   r   r   r   r   r   r*   )r   r   s   "€r    r!   ÚCsvDatasetWriter.__annotate__D   sS   ø€ ÷ +ñ +áð+ñ ™8¡XÐ-Õ.ð+ñ ™S•Mð	+ñ
 ™3•-ð+ñ "¡$�ñ+r#   c                óØ   € Ve   V^ 8:  d   \        RV R24      hWn        W n        V'       d   TM\        P                  V n        W@n        RV n        T;'       g    / V n        W`n	        R # )Nz	num_proc z must be an integer > 0.zutf-8)
Ú
ValueErrorr9   rF   r	   ÚDEFAULT_MAX_BATCH_SIZErG   r   ÚencodingrH   Úto_csv_kwargs)r,   r9   rF   rG   r   rH   rN   s   &&&&&&,r    r(   ÚCsvDatasetWriter.__init__D   sc   € ð Ò H°¤MÜ˜y¨¨
Ð2JÐKÓLÐLàŒØ&Ôß(2™*¼×8UÑ8UˆŒØ ŒØˆŒØ.×4Ð4°"ˆÔØ*Ör#   c                ó    <€ V ^8„  d   QhRS[ /# )r   Úreturn)r   )r   r   s   "€r    r!   rI   X   s   ø€ ÷ 
ñ 
‘sñ 
r#   c                ón  € V P                   P                  R R4      pV P                   P                  RR4      pV P                   P                  RR4      p\        V P                  \        \
        \        P                  34      '       dl   \        P                  ! V P                  R3/ V P                  ;'       g    / B ;_uu_ 4       pV P                  ! RRVRVRV/V P                   B pRRR4       V# V P                  ! RRV P                  RVRV/V P                   B pV#   + '       g   i     X# ; i)	rF   NÚheaderTÚindexFÚwbÚfile_objr&   )rN   Úpopr)   rF   r   ÚbytesÚosr   ÚfsspecÚopenrH   Ú_write)r,   Ú_rS   rT   ÚbufferÚwrittens   &     r    ÚwriteÚCsvDatasetWriter.writeX   s  € Ø×Ñ×"Ñ" =°$Ó7ˆØ×#Ñ#×'Ñ'¨°$Ó7ˆØ×"Ñ"×&Ñ& w°Ó6ˆä�d×&Ñ&¬¬e´R·[±[Ð(A×BÒBÜ—’˜T×-Ñ-¨tÑT¸×8LÑ8L×8RÐ8RÐPR×TÒTÐX^ØŸ+š+Ñh¨vÐh¸fÐhÈEÐhÐUY×UgÑUgÑh�÷ Uð ˆð —k’kÑn¨4×+;Ñ+;ÐnÀFÐnÐRWÐnÐ[_×[mÑ[mÑnˆGØˆ÷	 UÖTð ˆús   Ã#D#Ä#D4	c           	     ó@  € Vw  r#rE\        V P                  P                  \        W"V P                  ,           4      V P                  P
                  R 7      pVP                  4       P                  ! RRRRV^ 8X  d   TMRRV/VB pVP                  V P                  4      # ))ÚtableÚkeyÚindicesrF   NrS   FrT   r&   )
r
   r9   ÚdataÚslicerG   Ú_indicesÚ	to_pandasÚto_csvÚencoderM   )r,   ÚargsÚoffsetrS   rT   rN   ÚbatchÚcsv_strs   &&      r    Ú
_batch_csvÚCsvDatasetWriter._batch_csvd   s—   € Ø/3Ñ,ˆ˜äØ—,‘,×#Ñ#Ü�f t§¡Õ6Ó7Ø—L‘L×)Ñ)ô
ˆð
 —/‘/Ó#×*Ò*ñ 
Øð
Ø06¸!´¡VÀ%ð
ØOTð
ØXeñ
ˆð �~‰~˜dŸm™mÓ,Ð,r#   c                ó&   <€ V ^8„  d   QhRS[ RS[/# )r   rV   rQ   )r   r   )r   r   s   "€r    r!   rI   q   s   ø€ ÷ ñ ™xð ÉCñ r#   c                óú  € ^ pV P                   e   V P                   ^8X  dj   \        \        ^ \        V P                  4      V P
                  4      RRR7       F-  pV P                  WbW434      pWQP                  V4      ,          pK/  	  V# \        V P                  4      V P
                  r˜\        P                  ! V P                   4      ;_uu_ 4       p
\        T
P                  V P                  \        ^ W‰4       Uu. uF  qfW#V3NK	  	  up4      W‰,          '       d   W‰,          ^,           MW‰,          RRR7       F  pWQP                  V4      ,          pK  	  RRR4       V# u upi   + '       g   i     T# ; i)ztWrites the pyarrow table as CSV to a binary file handle.

Caller is responsible for opening and closing the handle.
NÚbazCreating CSV from Arrow format)ÚunitÚdesc)Útotalru   rv   )r   Úhf_tqdmÚrangeÚlenr9   rG   rp   r`   ÚmultiprocessingÚPoolÚimap)r,   rV   rS   rT   rN   r_   rm   ro   Únum_rowsrG   Úpools   &&&&,      r    r\   ÚCsvDatasetWriter._writeq   sA  € ð
 ˆà�=‰=Ò  D§M¡M°QÔ$6Ü!Ü�aœ˜TŸ\™\Ó*¨D¯O©OÓ<ØØ5÷�ð
 Ÿ/™/¨6¸5Ð*PÓQ�ØŸ>™>¨'Ó2Õ2’ñð, ˆô $' t§|¡|Ó#4°d·o±o�jÜ ×%Ò% d§m¡m×4Ô4¸Ü&Ø—I‘IØŸ™ÜNSÐTUÐW_ÔNlÓmÑNlÀF &°Ó?ÑNlÑmóð ;C×:OÔ:O˜8Õ1°QÖ6ÐU]ÕUkØØ9÷ �Gð Ÿ~™~¨gÓ6Õ6’Gñ ÷ 5ð ˆùò n÷	 5Ö4ð ˆús   Ã*E)Ã=E$Ä
AE)Å$E)Å)E:	)rG   r9   rM   r   rF   rH   rN   )NNN)
r<   r=   r>   r?   r(   r`   rp   r\   r@   rA   )r   s   @r    rD   rD   C   s(   ø‡ € ÷+ò +÷(
ð 
ò-÷ö r#   rD   )r{   rY   Útypingr   r   r   rZ   Ú r   r   r   r	   Ú
formattingr
   Úpackaged_modules.csv.csvr   Úutilsr   rx   Úutils.typingr   r   Úabcr   r   rD   r&   r#   r    Ú<module>rˆ      sC   ðÛ Û 	ß ,Ñ ,ã ç 4Ó 4Ý $Ý *Ý #ß <Ý &ô1Ð,ô 1÷hLó Lr#   