+
    QV-j°  ã                   ó¾   € ^ RI t ^ RIHt ^ RIHt ^ RIt^ RIHt  ! R R]4      t ! R R]4      t	 ! R	 R
]4      t
 ! R R]4      t ! R R]4      t ! R R]4      tR# )é    N)Úpartial)ÚOptional)ÚAbstractArchiveFileSystemc                   ó¦   a a€ ] tR t^	t oRtRtRtRtRtRV3R lV 3R lllt	]
V 3R l4       tR tV3R lR	 ltRV3R
 lR lltV3R ltRtVtV ;t# )ÚBaseCompressedFileFileSystemzFRead contents of compressed file as a filesystem with one file inside.Ú Nc                óL   <€ V ^8„  d   QhRS[ RS[S[ ,          RS[S[,          /# )é   ÚfoÚtarget_protocolÚtarget_options)Ústrr   Údict)ÚformatÚ__classdict__s   "€Úq/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/datasets/filesystems/compression.pyÚ__annotate__Ú)BaseCompressedFileFileSystem.__annotate__   s/   ø€ ÷ &ñ &Ùð&Ù-5±c­]ð&ÙS[Ñ\`ÕSañ&ó    c                ór  <€ \         SV `  ! V 3/ VB  \        VR4      '       d   VP                  4       MTV n        \        \        P                  V P                  3RRRTRV P                  RRRR	R
/T;'       g    / P                  R/ 4      C/T;'       g    / B V n
        \        P                  P                  V P                  P                  R4      ^ ,          4      V n        RV P                  9   d)   V P                  RV P                  P!                  R4       MV P                  V n        RV n        R# )aŽ  
The compressed file system can be instantiated from any compressed file.
It reads the contents of compressed file as a filesystem with one file inside, as if it was an archive.

The single file inside the filesystem is named after the compresssed file,
without the compression extension at the end of the filename.

Args:
    fo (:obj:``str``): Path to compressed file. Will fetch file using ``fsspec.open()``
    mode (:obj:``str``): Currently, only 'rb' accepted
    target_protocol(:obj:``str``, optional): To override the FS protocol inferred from a URL.
    target_options (:obj:``dict``, optional): Kwargs passed when instantiating the target FS.
Ú
__fspath__ÚmodeÚrbÚprotocolÚcompressionÚclient_kwargsÚrequote_redirect_urlFÚ	trust_envTz::Ú.N)ÚsuperÚ__init__Úhasattrr   r   r   ÚfsspecÚopenr   ÚpopÚ_open_with_fsspecÚosÚpathÚbasenameÚsplitÚcompressed_nameÚrindexÚuncompressed_nameÚ	dir_cache)Úselfr   r   r   ÚkwargsÚ	__class__s   &&&&,€r   r!   Ú%BaseCompressedFileFileSystem.__init__   s1  ø€ ô  	‰Ò˜Ñ( Ò(Ü%,¨R°×%>Ò%>�"—-‘-”/ÀBˆŒä!(Ü�K‰KØ�G‰Gñ"
ð ð"
ð %ð	"
ð
 ×(Ñ(ð"
ð '¨Ø˜Tðð "×'Ð' R×,Ñ,¨_¸bÓAðð"
ð ×#Ð# ñ"
ˆÔô  "Ÿw™w×/Ñ/°·±·±¸dÓ0CÀAÕ0FÓGˆÔð �d×*Ñ*Ô*ð × Ñ Ð!C 4×#7Ñ#7×#>Ñ#>¸sÓ#CÑDà×%Ñ%ð 	Ôð
 ˆŽr   c                ó@   <€ \         SV `  V4      P                  R 4      # )Ú/)r    Ú_strip_protocolÚlstrip)Úclsr(   r1   s   &&€r   r5   Ú,BaseCompressedFileFileSystem._strip_protocol;   s    ø€ ô ‰wÑ& tÓ,×3Ñ3°CÓ8Ð8r   c                óÌ   € V P                   fV   / V P                  4       P                  P                  V P                  4      CRV P
                  /CpVR,          V/V n         R # R # )NÚname)r.   r&   ÚfsÚinfor   r-   )r/   Úfs   & r   Ú	_get_dirsÚ&BaseCompressedFileFileSystem._get_dirs@   sU   € Ø�>‰>Ò!Ø]�4×)Ñ)Ó+×.Ñ.×3Ñ3°D·G±GÓ<Ð]¸fÀd×F\ÑF\Ñ]ˆAØ �i¨˜^ˆDŽNñ "r   c                ó    <€ V ^8„  d   QhRS[ /# )r
   r(   ©r   )r   r   s   "€r   r   r   E   s   ø€ ÷ ñ ™ñ r   c                ó¬   € V P                  4       P                  4       ;_uu_ 4       pVP                  4       uuR R R 4       #   + '       g   i     R # ; i)N)r&   r$   Úread)r/   r(   r=   s   && r   ÚcatÚ BaseCompressedFileFileSystem.catE   s4   € Ø×#Ñ#Ó%×*Ñ*×,Ô,°Ø—6‘6“8÷ -×,×,Ó,ús   §AÁA	c                ó&   <€ V ^8„  d   QhRS[ RS[ /# )r
   r(   r   rA   )r   r   s   "€r   r   r   I   s   ø€ ÷ /ñ /áð/ñ ñ/r   c                ó¦   € V P                  V4      pVR 8w  d   \        RV RV P                   R24      hV P                  4       P	                  4       # )r   zTried to read with mode z	 on file z opened with mode 'rb')r5   Ú
ValueErrorr   r&   r$   )r/   r(   r   Ú
block_sizeÚ
autocommitÚcache_optionsr0   s   &&&&&&,r   Ú_openÚ"BaseCompressedFileFileSystem._openI   sS   € ð ×#Ñ# DÓ)ˆØ�4Œ<ÜÐ7¸°v¸YÀtÇwÁwÀiÐOeÐfÓgÐgØ×%Ñ%Ó'×,Ñ,Ó.Ð.r   c                óN   <€ V ^8„  d   Qh/ S[ ;R&   S[ ;R&   S[S[ ,          ;R&   # )r
   r   r   Ú
extensions)r   Úlist)r   r   s   "€r   r   r   	   s2   ø‡ ‚ ñ ñ ñ	 ñ Ññ ñ ‘S•	Ñ ò r   )r&   r+   r.   r   r-   )r   NN)r   NTN)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Úroot_markerr   r   rO   r!   Úclassmethodr5   r>   rD   rL   Ú__annotate_func__Ú__static_attributes__Ú__classdictcell__Ú__classcell__)r1   r   s   @@r   r   r   	   sa   ù‡ € ÙPà€Kàð ð €KØ €J÷&õ &ðP ô9ó ð9ò,÷
ð ÷/ò /÷A … r   r   c                   ó(   € ] tR t^XtRtRtRtR.tRtR# )ÚBz2FileSystemz?Read contents of BZ2 file as a filesystem with one file inside.Úbz2z.bz2© N©	rQ   rR   rS   rT   rU   r   r   rO   rY   r_   r   r   r]   r]   X   ó   † ÙIà€HØ€KØ�„Jr   r]   c                   ó*   € ] tR t^`tRtRtRtRR.tRtR# )ÚGzipFileSystemz@Read contents of GZIP file as a filesystem with one file inside.Úgzipz.gzz.gzipr_   Nr`   r_   r   r   rc   rc   `   s   † ÙJà€HØ€KØ˜Ð!„Jr   rc   c                   ó(   € ] tR t^htRtRtRtR.tRtR# )ÚLz4FileSystemz?Read contents of LZ4 file as a filesystem with one file inside.Úlz4z.lz4r_   Nr`   r_   r   r   rf   rf   h   ra   r   rf   c                   ó(   € ] tR t^ptRtRtRtR.tRtR# )ÚXzFileSystemzFRead contents of .xz (LZMA) file as a filesystem with one file inside.Úxzz.xzr_   Nr`   r_   r   r   ri   ri   p   s   † ÙPà€HØ€KØ�„Jr   ri   c                   ó*   € ] tR t^xtRtRtRtRR.tRtR# )ÚZstdFileSystemzC
Read contents of .zstd file as a filesystem with one file inside.
Úzstdz.zstz.zstdr_   Nr`   r_   r   r   rl   rl   x   s   † ñð €HØ€KØ˜'Ð"„Jr   rl   )r'   Ú	functoolsr   Útypingr   r#   Úfsspec.archiver   r   r]   rc   rf   ri   rl   r_   r   r   Ú<module>rq      se   ðÛ 	Ý Ý ã Ý 4ôL/Ð#<ô L/ô^Ð0ô ô"Ð1ô "ôÐ0ô ôÐ/ô ô#Ð1ö #r   