+
    JV-j|:  ã                   ó   € R t ^ RIHtHt ^ RIHtHtHtHtH	t	H
t
HtHtHtHtHt ]t. t ^ RIHt  ^ RIHt  ^ RIHt  ^ R	IHtHtHtHtHtH t H!t!H"t"H#t#H$t$ ^ R
I%t%]%PL                  ! ]"4       R t'RR/R lt(RRR/R llt)RRRRR/R llt* ! R R]4      t+R
#   ] d    ]P+                  R4        L‚i ; i  ] d    ]P+                  R4        L™i ; i  ] d    ]P+                  R4        L°i ; i  ] d    ]P+                  R4        LŸi ; i)zO
FileSystem abstraction to interact with various local and remote filesystems.
)Ú_is_path_likeÚ_stringify_path)ÚFileSelectorÚFileTypeÚFileInfoÚ
FileSystemÚLocalFileSystemÚSubTreeFileSystemÚ_MockFileSystemÚFileSystemHandlerÚPyFileSystemÚ_copy_filesÚ_copy_files_selector)ÚAzureFileSystemr   )ÚHadoopFileSystemr   )ÚGcsFileSystemr   )
ÚAwsDefaultS3RetryStrategyÚAwsStandardS3RetryStrategyÚS3FileSystemÚ
S3LogLevelÚS3RetryStrategyÚensure_s3_initializedÚfinalize_s3Úensure_s3_finalizedÚinitialize_s3Úresolve_s3_regionNr   c                 óT   € V \         9   d   \        R V  R24      h\        RV  R24      h)z8The pyarrow installation is not built with support for 'Ú'z&module 'pyarrow.fs' has no attribute ')Ú_not_importedÚImportErrorÚAttributeError)Únames   &Ú[/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/pyarrow/fs.pyÚ__getattr__r#   I   sC   € ØŒ}ÔÜðØˆv�Qðó
ð 	
ô
 Ø
0°°°aÐ8óð ó    Úuse_mmapFc          	      óÞ  € \        V \        4      '       d   V # \        V \        4      '       d½   V'       d   \        R 4      h\        P                  ! V 4      w  r#VP                  V4      pV'       dw   VP                  V.4      ^ ,          pVP                  \        P                  8w  d4   \        RVP                  P                   RVP                   RV  R24      h\        WB4      pV#  ^ RIp\        WP                  4      '       d;   \        V 4      P                  R8X  d   \!        VR7      # \#        \%        V 4      4      #  \)        R\        V 4       R	24      h  \&         d     L%i ; i)
zXSpecifying to use memory mapping not supported for filesystem specified as an URI stringzWThe path component of the filesystem URI must point to a directory but it has a type: `z`. The path component is `z#` and the given filesystem URI is `Ú`Nr   ©r%   zUnrecognized filesystem: zP. `filesystem` argument must be a FileSystem instance or a valid file system URI)Ú
isinstancer   ÚstrÚ
ValueErrorÚfrom_uriÚnormalize_pathÚget_file_infoÚtyper   Ú	Directoryr!   Úpathr	   ÚfsspecÚAbstractFileSystemÚ__name__r   r   ÚFSSpecHandlerr   Ú	TypeError)Ú
filesystemr%   Úfsr1   ÚprefixÚprefix_infor2   s   &$     r"   Ú_ensure_filesystemr;   U   so  € Ü�*œj×)Ò)ØÐÜ	�J¤×	$Ò	$÷ Üð8óð ô ×&Ò& zÓ2‰ˆØ×"Ñ" 4Ó(ˆßà×*Ñ*¨F¨8Ó4°QÕ7ˆKØ×Ñ¤8×#5Ñ#5Ô5Ü ð5Ø5@×5EÑ5E×5JÑ5JÐ4Kð L%Ø%0×%5Ñ%5Ð$6ð 7Ø%˜, að)óð ô # 6Ó.ˆBØˆ	ð		?Ûô ˜*×&?Ñ&?×@Ò@Ü˜
Ó#×,Ñ,Ð0AÔAä*°HÔ=Ð=Ü#¤M°*Ó$=Ó>Ð>ð	 Aô Ø'¬¨ZÓ(8Ð'9ð :Bð Bó
ð 	
øô ô 	Ùð	ús   Ã,E ÅE,Å+E,Ú
memory_mapc               óª  € \        V 4      '       g   Ve   \        R4      hW3# Ved   \        WR7      p\        V\        4      '       d   \        V 4      p M!\        V \        4      '       g   \        R4      hVP                  V 4      p W3# \        V 4      p \	        VR7      p VP                  V 4      pVP                  \        P                  8g  pV'       g    \        P                  ! V 4      w  rW3# VP                  V 4      p W3#   \         d    RpRp LIi ; i  \         d&   p\        T4      pRT9   g   RT9   d    Rp?M
ThRp?ii ; i Y3# )z€
Return filesystem/path from path which could be an URI or a plain
filesystem path or a combination of fsspec protocol and URI.
Nzg'filesystem' passed but the specified path is file-like, so there is nothing to open with 'filesystem'.r(   zPExpected string path; path-like objects are only allowed with a local filesystemFzempty schemezCannot parse URI)r   r+   r;   r)   r   r   r*   r6   r-   r.   r/   r   ÚNotFoundr   r,   )r1   r7   r<   Ú	file_infoÚexists_locallyÚeÚmsgs   &&$    r"   Ú_resolve_filesystem_and_pathrC   ‚   sv  € ô
 ˜×ÒØÒ!Üð?óð ð ÐÐàÒÜ'¨
ÔHˆ
Ü�j¤/×2Ò2Ü" 4Ó(‰DÜ˜D¤#×&Ò&Üð*óð ð ×(Ñ(¨Ó.ˆØÐÐä˜4Ó €Dô
 !¨*Ô5€Jð?Ø×,Ñ,¨TÓ2ˆ	ð
 $Ÿ.™.¬H×,=Ñ,=Ñ=ˆ÷ ð
	Ü)×2Ò2°4Ó8ÑˆJð ÐÐð ×(Ñ(¨Ó.ˆàÐÐøô/ ô Øˆ	ØŠðûô ô 	Ü�a“&ˆCØ Ô$Ð(:¸cÔ(Aô à�ûð	úð ð ÐÐs0   Â#D	 ÃD Ä	DÄDÄEÄ)E	ÅE	Å	EÚ
chunk_sizeÚuse_threadsTc               óì   € \        W4      w  rg\        W4      w  r‰VP                  V4      p
V
P                  \        P                  8X  d   \        VRR7      p\        WkW‰WE4       R# \        WgW‰WE4       R# )aê  
Copy files between FileSystems.

This functions allows you to recursively copy directories of files from
one file system to another, such as from S3 to your local machine.

Parameters
----------
source : string
    Source file path or URI to a single file or directory.
    If a directory, files will be copied recursively from this path.
destination : string
    Destination file path or URI. If `source` is a file, `destination`
    is also interpreted as the destination file (not directory).
    Directories will be created as necessary.
source_filesystem : FileSystem, optional
    Source filesystem, needs to be specified if `source` is not a URI,
    otherwise inferred.
destination_filesystem : FileSystem, optional
    Destination filesystem, needs to be specified if `destination` is not
    a URI, otherwise inferred.
chunk_size : int, default 1MB
    The maximum size of block to read before flushing to the
    destination file. A larger chunk_size will use more memory while
    copying but may help accommodate high latency FileSystems.
use_threads : bool, default True
    Whether to use multiple threads to accelerate copying.

Examples
--------
Inspect an S3 bucket's files:

>>> s3, path = fs.FileSystem.from_uri(
...            "s3://registry.opendata.aws/roda/ndjson/")
>>> selector = fs.FileSelector(path)
>>> s3.get_file_info(selector)
[<FileInfo for 'registry.opendata.aws/roda/ndjson/index.ndjson':...]

Copy one file from S3 bucket to a local directory:

>>> fs.copy_files("s3://registry.opendata.aws/roda/ndjson/index.ndjson",
...               f"file:///{local_path}/index_copy.ndjson")

>>> fs.LocalFileSystem().get_file_info(str(local_path)+
...                                    '/index_copy.ndjson')
<FileInfo for '.../index_copy.ndjson': type=FileType.File, size=...>

Copy file using a FileSystem object:

>>> fs.copy_files("registry.opendata.aws/roda/ndjson/index.ndjson",
...               f"file:///{local_path}/index_copy.ndjson",
...               source_filesystem=fs.S3FileSystem())
T©Ú	recursiveN)rC   r.   r/   r   r0   r   r   r   )ÚsourceÚdestinationÚsource_filesystemÚdestination_filesystemrD   rE   Ú	source_fsÚsource_pathÚdestination_fsÚdestination_pathr?   Ú
source_sels   &&&&$$      r"   Ú
copy_filesrR   ¾   sz   € ôp :ØóÑ€Iô (DØó(Ñ$€Nð ×'Ñ'¨Ó4€IØ‡~�~œ×+Ñ+Ô+Ü! +¸Ô>ˆ
Ü˜YØ+Ø'ö	6ô 	�IØ"Øö	-r$   c                   ó¦   a € ] tR tRt o RtR tR tR tR tR t	]
R 4       tR	 tR
 tR tR tR tR tR tR tR tR tR tR tR tR tRtV tR# )r5   i	  zû
Handler for fsspec-based Python filesystems.

https://filesystem-spec.readthedocs.io/en/latest/index.html

Parameters
----------
fs : FSSpec-compliant filesystem instance

Examples
--------
>>> PyFileSystem(FSSpecHandler(fsspec_fs)) # doctest: +SKIP
c                ó   € Wn         R # ©N©r8   )Úselfr8   s   &&r"   Ú__init__ÚFSSpecHandler.__init__  s   € ØŽr$   c                ól   € \        V\        4      '       d   V P                  VP                  8H  # \        # rU   ©r)   r5   r8   ÚNotImplemented©rW   Úothers   &&r"   Ú__eq__ÚFSSpecHandler.__eq__  ó(   € Ü�eœ]×+Ò+Ø—7‘7˜eŸh™hÑ&Ð&ÜÐr$   c                ól   € \        V\        4      '       d   V P                  VP                  8g  # \        # rU   r[   r]   s   &&r"   Ú__ne__ÚFSSpecHandler.__ne__   ra   r$   c                óv   € V P                   P                  p\        V\        4      '       d
   V^ ,          pRV 2# )é    zfsspec+)r8   Úprotocolr)   Úlist)rW   rg   s   & r"   Úget_type_nameÚFSSpecHandler.get_type_name%  s4   € Ø—7‘7×#Ñ#ˆÜ�h¤×%Ò%Ø •{ˆHØ˜˜
Ð#Ð#r$   c                ó   € V# rU   © ©rW   r1   s   &&r"   r-   ÚFSSpecHandler.normalize_path+  s   € Øˆr$   c           	     óî   € VR ,          pVR,          R8X  d   \         P                  pM1VR,          R8X  d   \         P                  pRpM\         P                  p\	        WW!P                  RR4      R7      # )Úsizer/   ÚfileÚ	directoryNÚmtime)rp   rs   )r   ÚFiler0   ÚUnknownr   Úget)r1   Úinforp   Úftypes   &&  r"   Ú_create_file_infoÚFSSpecHandler._create_file_info.  s_   € à�F�|ˆØ��<˜6Ô!Ü—M‘M‰EØ�&�\˜[Ô(Ü×&Ñ&ˆEà‰Dä×$Ñ$ˆEÜ˜¨$·h±h¸wÈÓ6MÔNÐNr$   c                ó
  € . pV F?  p V P                   P                  V4      pVP                  V P                  W44      4       KA  	  V#   \         d.    TP                  \        T\        P                  4      4        K|  i ; irU   )r8   rw   Úappendry   ÚFileNotFoundErrorr   r   r>   )rW   ÚpathsÚinfosr1   rw   s   &&   r"   r.   ÚFSSpecHandler.get_file_info;  su   € ØˆÛˆDðAØ—w‘w—|‘| DÓ)�ð —‘˜T×3Ñ3°DÓ?Ö@ñ ð ˆøô	 %ô @Ø—‘œX d¬H×,=Ñ,=Ó>×?ð@ús   ‰A
Á
4BÂBc                óŒ  € V P                   P                  VP                  4      '       gj   V P                   P                  VP                  4      '       d   \	        VP                  4      hVP
                  '       d   . # \        VP                  4      hVP                  '       d   R pM^p. pV P                   P                  VP                  VRRR7      pVP                  4        FY  w  rVVP                  R4      pVP                  P                  R4      pWx8w  g   K9  VP                  V P                  WV4      4       K[  	  V# )NT)ÚmaxdepthÚwithdirsÚdetailÚ/)r8   ÚisdirÚbase_dirÚexistsÚNotADirectoryErrorÚallow_not_foundr}   rH   ÚfindÚitemsÚstripr|   ry   )	rW   Úselectorr‚   r   Úselected_filesr1   rw   Ú_pathr‡   s	   &&       r"   Úget_file_info_selectorÚ$FSSpecHandler.get_file_info_selectorF  s  € Ø�w‰w�}‰}˜X×.Ñ.×/Ò/Ø�w‰w�~‰~˜h×/Ñ/×0Ò0Ü(¨×):Ñ):Ó;Ð;à×+×+Ð+Ø�Iä+¨H×,=Ñ,=Ó>Ð>à××ÐØ‰HàˆHàˆØŸ™Ÿ™Ø×Ñ¨¸4Èð &ó 
ˆð )×.Ñ.Ö0‰JˆDØ—J‘J˜s“OˆEØ×(Ñ(×.Ñ.¨sÓ3ˆHð Ö Ø—‘˜T×3Ñ3°DÓ?Ö@ñ 1ð ˆr$   c                ód   €  V P                   P                  WR 7       R#   \         d     R# i ; i))Úcreate_parentsN)r8   ÚmkdirÚFileExistsError)rW   r1   rH   s   &&&r"   Ú
create_dirÚFSSpecHandler.create_dirc  s+   € ð	Ø�G‰G�M‰M˜$ˆMÖ9øÜô 	Úð	ús   ‚   /®/c                ó@   € V P                   P                  VR R7       R# ©TrG   N)r8   Úrmrm   s   &&r"   Ú
delete_dirÚFSSpecHandler.delete_dirj  s   € Ø�‰�
‰
�4 4ˆ
Ö(r$   c                ó†  €  V P                   P                  VR R7      pT F�  pT P                   P                  T4      '       d    T P                   P	                  TRR7       KC  T P                   P                  T4      '       g   Kf  T P                   P	                  T4       Kƒ  	  R#   \         d    T'       d    R# h i ; i)F)r„   NTrG   )r8   Úlistdirr}   r†   r›   Úisfile)rW   r1   Úmissing_dir_okÚsubpathsÚsubpaths   &&&  r"   Ú_delete_dir_contentsÚ"FSSpecHandler._delete_dir_contentsm  s�   € ð	Ø—w‘w—‘ t°E�Ó:ˆHó
  ˆGØ�w‰w�}‰}˜W×%Ò%Ø—‘—
‘
˜7¨d�
Ö3Ø—‘—‘ ×(Ô(Ø—‘—
‘
˜7Ö#ó	  øô	 !ô 	ßÚØð	ús   ‚B( Â(C Â>C c                ón   € VP                  R 4      R8X  d   \        RVR4      hV P                  W4       R# )r…   Ú z$delete_dir_contents called on path 'r   N)r�   r+   r¤   )rW   r1   r¡   s   &&&r"   Údelete_dir_contentsÚ!FSSpecHandler.delete_dir_contentsz  s6   € Ø�:‰:�c‹?˜bÔ ÜØ6¸¸cóCð Cà×!Ñ! $Ö7r$   c                ó*   € V P                  R R4       R# )r…   FN)r¤   )rW   s   &r"   Údelete_root_dir_contentsÚ&FSSpecHandler.delete_root_dir_contents€  s   € Ø×!Ñ! # uÖ-r$   c                ó”   € V P                   P                  V4      '       g   \        V4      hV P                   P                  V4       R # rU   )r8   rˆ   r}   r›   rm   s   &&r"   Údelete_fileÚFSSpecHandler.delete_fileƒ  s2   € ð �w‰w�~‰~˜d×#Ò#Ü# DÓ)Ð)Ø�‰�
‰
�4Ör$   c                ó@   € V P                   P                  WR R7       R# rš   )r8   Úmv©rW   ÚsrcÚdests   &&&r"   ÚmoveÚFSSpecHandler.moveŠ  s   € Ø�‰�
‰
�3¨ˆ
Ö-r$   c                ó<   € V P                   P                  W4       R # rU   )r8   Úcopyr²   s   &&&r"   Ú	copy_fileÚFSSpecHandler.copy_file�  s   € ð 	�‰�‰�SÖr$   c                ó°   € ^ RI Hp V P                  P                  V4      '       g   \	        V4      hV! V P                  P                  VRR7      RR7      # ©rf   ©Ú
PythonFileÚrb©ÚmodeÚr©Úpyarrowr¾   r8   r    r}   Úopen©rW   r1   r¾   s   && r"   Úopen_input_streamÚFSSpecHandler.open_input_stream”  óA   € Ý&à�w‰w�~‰~˜d×#Ò#Ü# DÓ)Ð)á˜$Ÿ'™'Ÿ,™, t°$˜,Ó7¸cÔBÐBr$   c                ó°   € ^ RI Hp V P                  P                  V4      '       g   \	        V4      hV! V P                  P                  VRR7      RR7      # r¼   rÃ   rÆ   s   && r"   Úopen_input_fileÚFSSpecHandler.open_input_fileœ  rÉ   r$   c                óX   € ^ RI Hp V! V P                  P                  VRR7      RR7      # )rf   r½   ÚwbrÀ   Úw©rÄ   r¾   r8   rÅ   ©rW   r1   Úmetadatar¾   s   &&& r"   Úopen_output_streamÚ FSSpecHandler.open_output_stream¤  ó#   € Ý&á˜$Ÿ'™'Ÿ,™, t°$˜,Ó7¸cÔBÐBr$   c                óX   € ^ RI Hp V! V P                  P                  VRR7      RR7      # )rf   r½   ÚabrÀ   rÏ   rÐ   rÑ   s   &&& r"   Úopen_append_streamÚ FSSpecHandler.open_append_stream©  rÕ   r$   rV   N)r4   Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__rX   r_   rc   ri   r-   Ústaticmethodry   r.   r‘   r—   rœ   r¤   r¨   r«   r®   rµ   r¹   rÇ   rË   rÓ   rØ   Ú__static_attributes__Ú__classdictcell__)Ú__classdict__s   @r"   r5   r5   	  s‰   ø‡ € ñòòò
ò
$òð ñ
Oó ð
Oò	òò:ò)ò$ò8ò.òò.ò òCòCòC÷
Cð Cr$   r5   rU   )NNi   ),rÝ   Úpyarrow.utilr   r   Úpyarrow._fsr   r   r   r   r   r	   r
   r   r   r   r   Ú	FileStatsr   Úpyarrow._azurefsr   r   r|   Úpyarrow._hdfsr   Úpyarrow._gcsfsr   Úpyarrow._s3fsr   r   r   r   r   r   r   r   r   r   ÚatexitÚregisterr#   r;   rC   rR   r5   rl   r$   r"   Ú<module>rë      s5  ðñ$÷ 8÷÷ ÷ ñ ð €	à€ð,Ý0ð-Ý.ð*Ý,ð)÷L÷ L÷ Ló Ø
‡O‚OÐ'Ô(ò	ð*
¨uô *
ñZ9Àeõ 9ñxH-à&ðH-à48õH-ôVcCÐ%ö cCøð{ ô ,Ø×ÑÐ*Ö+ð,ûð
 ô -Ø×ÑÐ+Ö,ð-ûð
 ô *Ø×Ñ˜Ö)ð*ûð ô )Ø×Ñ˜Ö(ð)úsD   ªB ±B6 ¸C ¿C2 ÂB3Â2B3Â6CÃCÃC/Ã.C/Ã2DÄD