+
    LV-jÑ’  ã                   ó’  € ^ RI t ^ RIt ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	H
t
 ^ RIHt ^ RIHt ^RIHt ^RIHt ^RIHtHtHt ^RIHtHt ^R	IHtHtHt ]P<                  ! R
4      tR.t R.t!Rs"] PF                  t#R t$R t%R%R lt&RR/R lt'R%R lt(R t)R t*]+! ]R4      '       d   ]PX                  ! ]*R7       ]'       d   ^ RI-t-]-P\                  t/M ^ RI-t-]0! ]-R]14      t/^€t3Rt4R&R lt5R R lt6R]RRR3R lt7. R'Ot8 ! R R]4      t9R t: ! R R ];4      t<R!R!]<R3R" lt= ! R# R$]4      t>R#   ]2 d    Rt-]1t/ LYi ; i)(é    N)ÚIterable)Ú	has_magic)ÚTYPE_CHECKING)ÚDEFAULT_CALLBACK)ÚFSTimeoutError)ÚLocalFileSystemÚmake_path_posixÚtrailing_sep)ÚAbstractBufferedFileÚAbstractFileSystem)Úglob_translateÚis_exceptionÚother_pathsz_[^_]c                 óP   € \         '       g   \        P                  ! 4       s \         # )zwAllocate or return a threading lock.

The lock is allocated on first use to allow setting one lock per forked process.
)Ú_lockÚ	threadingÚLock© ó    Ú\/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/fsspec/asyn.pyÚget_lockr      s   € ÷ ‹5Ü—’Ó ˆÜ€Lr   c                 ó.   € R\         ^ &   R\        ^ &   RsR# )z¡Reset the global lock.

This should be called only on the init of a forked process to reset the lock to
None, enabling the new forked process to get a new lock.
N)ÚiothreadÚloopr   r   r   r   Ú
reset_lockr   &   s   € ð „HˆQ�KØ„Dˆ�GØ‚Er   c              ƒ   óþ   "  € V'       d   TMR pVe   \         P                  ! WR7      p VG R j  x€L
 V^ &   V P                  4        R #  L  \         d   pYB^ &    R p?L(R p?ii ; i  T P                  4        i ; i5i)N©Útimeout)ÚasyncioÚwait_forÚ	ExceptionÚset)ÚeventÚcoroÚresultr   Úexs   &&&& r   Ú_runnerr'   3   sf   é € ß ‰g d€GØÒÜ×Ò Ô6ˆðØ—Jˆˆq‰	ð 	�	‰	Žñ	 øÜô ØˆqŽ	ûðûð 	�	‰	�üsI   ‚(A=«A °A
±A ¸A=Á
A ÁA%ÁA ÁA( Á A%Á%A( Á(A:Á:A=r   c               ó€  € V'       d   TMRpV e   V P                  4       '       d   \        R4      h \        P                  P	                  4       pWPJ d   \        R4      h T! T/ TB pR.p\        P                  ! 4       p\        P                  ! \        Y†Yr4      T 4        TP                  ^4      '       d   MTf   K  T^,          pT^ 8  g   K1  \        hT^ ,          p	\        T	\        P                  4      '       d   \        T	h\        T	\        4      '       d   T	hT	#   \
         d    h \         d     LÚi ; i)z½
Make loop run coroutine until it returns. Runs in other thread

Examples
--------
>>> fsspec.asyn.sync(fsspec.asyn.get_loop(), func, *args,
                     timeout=timeout, **kwargs)
NzLoop is not runningz)Calling sync() from within a running loop)Ú	is_closedÚRuntimeErrorr   ÚeventsÚget_running_loopÚNotImplementedErrorr   ÚEventÚrun_coroutine_threadsafer'   Úwaitr   Ú
isinstanceÚTimeoutErrorÚBaseException)
r   Úfuncr   ÚargsÚkwargsÚloop0r$   r%   r#   Úreturn_results
   &&$*,     r   Úsyncr9   ?   s  € ÷ !‰g d€Gð ‚|�t—~‘~×'Ò'ÜÐ0Ó1Ð1ðÜ—‘×/Ñ/Ó1ˆØ‹=Ü%Ð&QÓRÐRð ñ �Ð ˜Ñ €DØˆV€FÜ�OŠOÓ€EÜ×$Ò$¤W¨U¸&Ó%JÈDÔQØ
à�:‰:�a�=Š=ØØÔØ�q�LˆGØ˜Ž{Ü$Ð$à˜1•I€MÜ�-¤×!5Ñ!5×6Ò6ä -Ð/Ü	�M¤=×	1Ò	1ØÐàÐøô1 ô ØÜô Ùðús   ³.D$ Ä$D=Ä9D=Ä<D=c                óJ   a a€ \         P                  ! S 4      V V3R l4       pV# )z©Given a function, make so can be called in blocking contexts

Leave obj=None if defining within a class. Pass the instance if attaching
as an attribute of the instance.
c                  ó^   <€ S;'       g
    V ^ ,          p\        VP                  S.V O5/ VB # )r   )r9   r   )r5   r6   Úselfr4   Úobjs   *, €€r   ÚwrapperÚsync_wrapper.<locals>.wrappers   s-   ø€ à�~ˆ~�d˜1•gˆÜ�D—I‘I˜tÐ5 dÒ5¨fÑ5Ð5r   )Ú	functoolsÚwraps)r4   r=   r>   s   ff r   Úsync_wrapperrB   l   s'   ù€ ô ‡_‚_�TÓõ6ó ð6ð €Nr   c                 ó¸  € \         ^ ,          f¡   \        4       ;_uu_ 4        \         ^ ,          fj   \        P                  ! 4       \         ^ &   \        P
                  ! \         ^ ,          P                  RR7      p RV n        V P                  4        V \        ^ &   RRR4       \         ^ ,          # \         ^ ,          #   + '       g   i     \         ^ ,          # ; i)z\Create or return the default fsspec IO loop

The loop will be running on a separate thread.
NÚfsspecIO)ÚtargetÚnameT)
r   r   r   Únew_event_loopr   ÚThreadÚrun_foreverÚdaemonÚstartr   )Úths    r   Úget_looprM   {   s‘   € ô
 ˆA…w‚Ü�Z�Zô �A�wŠÜ!×0Ò0Ó2”�Q‘Ü×%Ò%¬T°!­W×-@Ñ-@ÀzÔR�Ø �”	Ø—‘”
Ø ”˜‘÷ ô ��7€NŒ4��7€N÷ ŽZô ��7€Nús   ¢A9B=Â=C	c                  ó.   € R \         ^ &   R \        ^ &   R sR # ©N)r   r   Úlockr   r   r   Úreset_after_forkrQ   �   s   € à„Dˆ�GØ„HˆQ�KØ‚Dr   Úregister_at_fork)Úafter_in_childÚerrori   Fc                 ój  € ^ RI Hp V '       d   RV9   d
   VR,          # MRV9   d
   VR,          # V '       d   \        # \        f   \        #  \        P
                  ! \        P                  4      w  r#T\        P                  8X  d   R# T^,          #   \        \        \        3 d
    \        u # i ; i)r   )ÚconfÚnofiles_gather_batch_sizeÚgather_batch_sizeéÿÿÿÿ)Úfsspec.configrV   Ú_NOFILES_DEFAULT_BATCH_SIZEÚresourceÚ_DEFAULT_BATCH_SIZEÚ	getrlimitÚRLIMIT_NOFILEÚImportErrorÚ
ValueErrorÚResourceErrorÚRLIM_INFINITY)ÚnofilesrV   Ú
soft_limitÚ_s   &   r   Ú_get_batch_sizerg   ª   s¦   € Ý"çØ&¨$Ô.ØÐ3Õ4Ð4ð /ð  $Ô&ØÐ+Õ,Ð,ßÜ*Ð*ÜÒÜ"Ð"ð#Ü ×*Ò*¬8×+AÑ+AÓB‰ˆ
ð ”X×+Ñ+Ô+Øˆ	à˜Q�Ðøô œ¤]Ð3ô #Ü"Ò"ð#ús   Á&B ÂB2Â1B2c                ó$   € V ^8„  d   QhR\         /# )é   Úreturn)Úbool)Úformats   "r   Ú__annotate__rm   Ã   s   € ÷ ñ ”tñ r   c                 óV   €  \         P                  ! 4        R#   \         d     R# i ; i)z Being executed by an event loop?TF)r   r,   r*   r   r   r   Úrunning_asyncro   Ã   s(   € ðÜ× Ò Ô"ÙøÜô Úðús   ‚ ™(§(c              ƒ  ó4  aaa"  € Vf   \        VR7      pVR8X  d   \        V 4      pV^ 8”  g   Q hVVV3R lp^ p\        V 4      pR.V,          p	\        4       p
V
'       g   Wx8  Ed   \        V
4      V8  dD   Wx8  d>   V
P                  \        P
                  ! V! W,          V4      4      4       V^,          pKS  V
'       g    V	# \        P                  ! V
\        P                  R7      G Rj  x€L
 w  rºRpV'       d$   VP                  4       p VG Rj  x€L
 w  rïWéV&   K+  Vf   KÐ  V
 F  pVP                  4        K  	  V
'       d   \        P                  ! V
RR/ G Rj  x€L
  VhV	#  L| LW  \         d   pTf	   Tp Rp?K�   Rp?K•  Rp?ii ; i L15i)a  Run the given coroutines in  chunks.

Parameters
----------
coros: list of coroutines to run
batch_size: int or None
    Number of coroutines to submit/wait on simultaneously.
    If -1, then it will not be any throttling. If
    None, it will be inferred from _get_batch_size()
callback: fsspec.callbacks.Callback instance
    Gets a relative_update when each coroutine completes
timeout: number or None
    If given, each coroutine times out after this time. Note that, since
    there are multiple batches, the total run time of this function will in
    general be longer
return_exceptions: bool
    Same meaning as in asyncio.gather
nofiles: bool
    If inferring the batch_size, does this operation involve local files?
    If yes, you normally expect smaller batches.
N)rd   c              “   ó  <"  €  \         P                  ! V SR 7      G Rj  x€L
 V3SP                  ^4       #  L  \         d(   pS'       g   h Y!3u Rp?SP                  ^4       # Rp?ii ; i  SP                  ^4       i ; i5i)r   N)r   r    Úrelative_updater!   )r$   ÚiÚeÚcallbackÚreturn_exceptionsr   s   && €€€r   Ú	_run_coroÚ'_run_coros_in_chunks.<locals>._run_coroò   st   øé € ð	(Ü ×)Ò)¨$¸Ô@×@À!ÐCð ×$Ñ$ QÕ'ñ AøÜô 	ß$ØØ�4ŒKà×$Ñ$ QÕ'ûð	ûð
 ×$Ñ$ QÕ'üsO   ƒB…:  8¡: ¦B¸: ºA,ÁA'ÁA,ÁA/ ÁBÁ'A,Á,A/ Á/BÂB)Úreturn_whenrv   TrY   )rg   Úlenr"   Úaddr   Úensure_futurer0   ÚFIRST_COMPLETEDÚpopr!   ÚcancelÚgather)ÚcorosÚ
batch_sizeru   r   rv   rd   rw   rs   ÚnÚresultsÚpendingÚdoneÚ	first_excÚtaskr%   ÚkÚexcs   &&fff&           r   Ú_run_coros_in_chunksr‹   Ì   s^  úé € ð< ÒÜ$¨WÔ5ˆ
à�RÔÜ˜“Zˆ
à˜Œ>Ðˆ>÷(ð 	
€AÜˆE‹
€AØˆf�q�j€GÜ‹e€Gç
�Q•UÜ�'‹l˜ZÔ'¨A¬EØ�K‰Kœ×-Ò-©i¸½À!Ó.DÓEÔFØ��FŠAçØð( €Nô% &Ÿlšl¨7Ä×@WÑ@WÔX×X‰ˆØˆ	ßØ—8‘8“:ˆDð$Ø"&ŸJ‘	�Ø#˜“
ð
 Ô Û�Ø—‘–ñ  çÜ—n’n gÐFÀÑF×FÐFØˆOà€Nñ% Yñ
 'øäô $ØÒ$Ø #–Iõ %ûð$úñ Gùsy   …AFÁ"A!FÃ,FÃ0E-Ã1FÄFÄE1 ÄE/Ä
E1 Ä"FÄ* FÅFÅ$FÅ%	FÅ/E1 Å1FÅ<FÆFÆFÆFc                   ót  a a€ ] tR tRt oRtRtRtRtRRRRRR/V 3R	 llt]	R
 4       t
R tR*R ltR tR tR+R ltR,R ltR-R ltR tR-R ltR.R ltR/R ltR,R ltR]RR3R ltR tR]R3R ltR tR tR tR0R ltR tR t R1R  lt!R2R! lt"R0R" lt#R3R# lt$R4R$ lt%R*R% lt&R1R& lt'R5R' lt(R6R( lt)R)t*Vt+V ;t,# )7ÚAsyncFileSystemi6  aW  Async file operations, default implementations

Passes bulk operations to asyncio.gather for concurrent operation.

Implementations that have concurrent batch operations and/or async methods
should inherit from this class instead of AbstractFileSystem. Docstrings are
copied from the un-underscored method in AbstractFileSystem, if not given.
TFÚasynchronousr   Nr‚   c               óÆ   <€ Wn         \        P                  ! 4       V n        V'       g   T;'       g    \	        4       V n        MR V n        W0n        \        SV `   ! V/ VB  R # rO   )	rŽ   ÚosÚgetpidÚ_pidrM   Ú_loopr‚   ÚsuperÚ__init__)r<   rŽ   r   r‚   r5   r6   Ú	__class__s   &$$$*,€r   r•   ÚAsyncFileSystem.__init__G  sH   ø€ Ø(ÔÜ—I’I“KˆŒ	ßØ×+Ð+¤£ˆD�JàˆDŒJØ$ŒÜ‰Ò˜$Ð) &Ô)r   c                óx   € V P                   \        P                  ! 4       8w  d   \        R 4      hV P                  # )zThis class is not fork-safe)r’   r�   r‘   r*   r“   ©r<   s   &r   r   ÚAsyncFileSystem.loopQ  s*   € à�9‰9œŸ	š	›Ô#ÜÐ<Ó=Ð=Ø�z‰zÐr   c              ‹  óò   "  € \         P                  ! V P                  4      '       dG   \        V 4      P                  \        P                  Jd    V P                  ! V3R RR^/VB G Rj  x€L
 # \
        h L
5i)Ú	recursiveFr‚   N)ÚinspectÚiscoroutinefunctionÚ_rmÚtyper�   r-   ©r<   Úpathr6   s   &&,r   Ú_rm_fileÚAsyncFileSystem._rm_fileW  s]   é € ä×'Ò'¨¯©×1Ò1Ü�T“
—‘¤o×&9Ñ&9Ó9àŸš $ÑP°%ÐPÀAÐPÈÑP×PÐPÜ!Ð!ñ Qùs   ‚A(A7Á*A5Á+A7c           
   ‹  óú   "  € T;'       g    V P                   pV P                  WR 7      G Rj  x€L
 p\        \        V4       Uu. uF  qPP                  ! V3/ VB NK  	  upVRR7      G Rj  x€L
 #  LCu upi  L5i)©rœ   NT©r‚   rd   )r‚   Ú_expand_pathr‹   Úreversedr£   )r<   r¢   rœ   r‚   r6   Úps   &&&&, r   rŸ   ÚAsyncFileSystem._rm_  st   é € à×2Ð2 4§?¡?ˆ
Ø×&Ñ& tÐ&ÓA×AˆÜ)Ü19¸$´Ó@±¨A�]Š]˜1Ñ' Ô'±Ñ@Ø!Øô
÷ 
ð 	
ñ Bùâ@ñ
ùs-   ‚,A;®A2¯A;ÁA4Á A;Á-A9Á.A;Á4A;c              ‹  ó   "  € \         h5irO   ©r-   )r<   Úpath1Úpath2r6   s   &&&,r   Ú_cp_fileÚAsyncFileSystem._cp_filei  ó   é € Ü!Ð!ùó   ‚	c              ƒ  óz   "  € V P                  W4      G R j  x€L
  V P                  V4      G R j  x€L
  R #  L L5irO   )r°   r£   )r<   r®   r¯   s   &&&r   Ú_mv_fileÚAsyncFileSystem._mv_filel  s1   é € Ø�m‰m˜EÓ)×)Ð)Ø�m‰m˜EÓ"×"Ò"ñ 	*Ù"ùs   ‚;—7˜;°9±;¹;c           	   ‹  óŠ  "  € Vf   V'       d   RpMVf   Rp\        V\        4      '       d   \        V\        4      '       d   TpTp	EMM\        V\        4      p
V P                  WVR7      G R j  x€L
 pV
'       d\   V'       d   VeP   V Uu. uF9  p\	        V4      '       d   K  V P                  V4      G R j  x€L
 '       d   K7  VNK;  	  ppV'       g   R # \        V4      ^8H  p\        V\        4      ;'       d-    \	        V4      ;'       g    V P                  V4      G R j  x€L
 pT
;'       dP    \        V4      ;'       d    T;'       g3    \        V4      '       * ;'       d    T;'       d    \	        V4      '       * p\        VVVV
'       * R7      p	T;'       g    V P                  p\        W‰4       UUu. uF  w  ppV P                  ! VV3/ VB NK  	  ppp\        VVRRR7      G R j  x€L
 p\        \        V4       F"  pVR8X  d   \        V\        4      '       d   K"  Vh	  R #  EL½ ELwu upi  ELu uppi  LP5i)NÚignoreÚraise)Úmaxdepthrœ   ©ÚexistsÚflattenT)r‚   rv   rd   )r1   ÚlistÚstrr¨   r
   Ú_isdirrz   r   r   r‚   Úzipr°   r‹   Úfilterr   ÚFileNotFoundError)r<   r®   r¯   rœ   Úon_errorrº   r‚   r6   Úpaths1Úpaths2Úsource_is_strrª   Úsource_is_fileÚdest_is_dirr¼   Úp1Úp2r�   r%   r&   s   &&&&&&&,            r   Ú_copyÚAsyncFileSystem._copyp  s  é € ð Ò§	Ø‰HØÒØˆHä�eœT×"Ò"¤z°%¼×'>Ò'>ð ˆFØŠFä& u¬cÓ2ˆMØ×,Ñ,Ø°Ið -ó ÷ ˆF÷ §i°8Ò3Gñ  &óÙ%˜!¬l¸1¯o”AÀtÇ{Á{ÐSTÃ~×AUÓAU—A�A™vð ð ÷ Ùä  ›[¨AÑ-ˆNÜ$ U¬CÓ0÷ ð Ü˜UÓ#×?Ð?¨T¯[©[¸Ó-?×'?ð ð #÷ ð Ü˜5Ó!×4Ð4 n÷ Vð VÜ! %Ó(Ô(×TÐT¨[×TÐTÄÈeÓATÔ=Tð ô !ØØØØ)Ô)ô	ˆFð  ×2Ð2 4§?¡?ˆ
Ü?BÀ6Ô?RÔSÑ?R±V°R¸�—’˜r 2Ñ0¨Ô0Ñ?RˆÑSÜ+Ø˜j¸DÈ$ô
÷ 
ˆô œ vÖ.ˆBØ˜8Ô#¬
°2Ô7H×(IÒ(IÙØˆHó /òCò BVùòò (@ùó Tñ
ùs­   ‚I�A!IÁ0H-Á1IÁ=IÂIÂH3Â%H3Â9H0
Â:H3ÃH3Ã0IÃ=IÄIÄ%H8Ä&IÄ3IÅ	IÅIÅ(	IÅ2-IÆ IÆ; H;ÇIÇ0IÇ1=IÈ0H3È3IÈ;Ic              ‹  ó   "  € \         h5irO   r­   )r<   r¢   ÚvalueÚmoder6   s   &&&&,r   Ú
_pipe_fileÚAsyncFileSystem._pipe_file¬  r²   r³   c              ‹  ó
  "  € \        V\        4      '       d   W/pT;'       g    V P                  p\        VP	                  4        UUu. uF  w  rVV P
                  ! WV3/ VB NK  	  uppVR R7      G Rj  x€L
 # u uppi  L
5i)Tr§   N)r1   r¿   r‚   r‹   ÚitemsrÑ   )r<   r¢   rÏ   r‚   r6   r‰   Úvs   &&&&,  r   Ú_pipeÚAsyncFileSystem._pipe¯  sr   é € Ü�dœC× Ò Ø�=ˆDØ×2Ð2 4§?¡?ˆ
Ü)Ø9=¿¹¼ÔF¹±°ˆT�_Š_˜QÑ, VÔ,¹ÒFØ!Øô
÷ 
ð 	
ùÛFñ
ùs"   ‚"B¥%BÁ
A;
Á(BÁ6BÁ7Bc              ƒ  ó¼  "  € RpRpVeG   V^ 8  d@   Vf	   V) pRpRpM9T;'       g!    V P                  V4      G Rj  x€L
 R,          pWB,           pMVf   ^ pV'       gr   Ve?   V^ 8  d8   Ve3   T;'       g!    V P                  V4      G Rj  x€L
 R,          pWC,           pMVf   Rp\        V\        P                  4      '       d
   V^,          pRV RV 2#  L› LM5i)z"Helper for "Range"-based _cat_fileNFÚ TÚsizezbytes=Ú-)Ú_infor1   ÚnumbersÚIntegral)r<   ÚurlrK   ÚendrÚ   Úsuffs   &&&&  r   Ú_process_limitsÚAsyncFileSystem._process_limits¹  sÛ   é € àˆØˆØÒ ¨¤àŠ{Ø�f�Ø�Ø‘à×>Ð> d§j¡j°£o× 5°vÕ>�Ø�‘ØŠ]ØˆEßØŠ 3¨¤7ØÒ$Ø×BÐB¨$¯*©*°S«/×$9¸6Õ#B�DØ�*�CøØ’Ø�Ü˜#œw×/Ñ/×0Ò0Ø�q•�Ø˜�w˜a ˜uÐ%Ð%ñ !6ñ %:ùs3   ‚$C§C¼C½!CÁCÁ7CÂCÂACÃCc              ‹  ó   "  € \         h5irO   r­   )r<   r¢   rK   rà   r6   s   &&&&,r   Ú	_cat_fileÚAsyncFileSystem._cat_fileÓ  r²   r³   c              ‹  óX  "  € V P                  WR 7      G Rj  x€L
 pV Uu. uF  qP                  ! V3/ VB NK  	  ppT;'       g    V P                  p\        WtRRR7      G Rj  x€L
 pVR8X  d%   \	        \        \        V4      R4      p	V	'       d   V	h\        V4      ^8”  g4   \        X\        4      '       g   V^ ,          V P                  V4      8w  d:   \        Wh4       U
Uu/ uF!  w  r«VR8w  g   \        V4      '       d   K  W«bK#  	  upp
# V^ ,          #  ELu upi  L¼u upp
i 5i)r¦   NT©r‚   rd   rv   r¹   FÚomit)r¨   rå   r‚   r‹   ÚnextrÂ   r   rz   r1   r¾   Ú_strip_protocolrÁ   )r<   r¢   rœ   rÄ   r‚   r6   Úpathsr�   Úoutr&   r‰   rÕ   s   &&&&&,      r   Ú_catÚAsyncFileSystem._catÖ  s  é € ð ×'Ñ'¨Ð'ÓB×BˆÙ<AÓB¹E°D—’ Ñ/¨Ô/¹EˆÐBØ×2Ð2 4§?¡?ˆ
Ü(Ø°$È$ô
÷ 
ˆð �wÔÜ”fœ\¨3Ó/°Ó7ˆBßØ�ä�‹J˜ŒNÜ˜$¤×%Ò%Ø�Q�x˜4×/Ñ/°Ó5Ô5ô   œOôá+‘D�AØ˜vÔ%¬\¸!¯_ô �’Ù+òð ð �q•6ˆMò+ CùÚBñ
ùóùsJ   ‚D*˜D™D*¡D¼
D*ÁD*Á%D"Á&B D*Ã&D$ÄD$ÄD*ÄD*Ä$D*c              ‹  óB  "  € Ve   \         h\        V\        4      '       g   \        h\        V\        4      '       g   V.\        V4      ,          p\        V\        4      '       g   V.\        V4      ,          p\        V4      \        V4      8w  g   \        V4      \        V4      8w  d   \        h\        WV4       UU	U
u. uF  w  r‰p
V P                  ! V3RV	RV
/VB NK  	  pp	pp
T;'       g    V P                  p\        WµRRR7      G Rj  x€L
 # u up
p	pi  L5i)a  Get the contents of byte ranges from one or more files

Parameters
----------
paths: list
    A list of of filepaths on this filesystems
starts, ends: int or list
    Bytes limits of the read. If using a single int, the same value will be
    used to read all the specified files.
NrK   rà   Trè   )r-   r1   r¾   Ú	TypeErrorr   rz   ra   rÁ   rå   r‚   r‹   )r<   rì   ÚstartsÚendsÚmax_gapr‚   rÄ   r6   rª   Úsrt   r�   s   &&&&&&&,    r   Ú_cat_rangesÚAsyncFileSystem._cat_rangesð  sÿ   é € ð* Òä%Ð%Ü˜%¤×&Ò&ÜˆOÜ˜&¤(×+Ò+Ø�X¤ E£
Õ*ˆFÜ˜$¤×)Ò)Ø�6œC ›JÕ&ˆDÜˆv‹;œ#˜e›*Ô$¬¨D«	´S¸³ZÔ(?ÜÐô ˜u¨dÔ3õ
á3‘��að �NŠN˜1Ñ7 AÐ7¨1Ð7°Ô7Ù3ð 	ò 
ð  ×2Ð2 4§?¡?ˆ
Ü)Ø°$È$ô
÷ 
ð 	
ùô
ñ

ùs$   ‚CDÃ#DÃ&DÃ3DÄDÄDc              ‹  ó   "  € \         h5irO   r­   )r<   ÚlpathÚrpathrÐ   r6   s   &&&&,r   Ú	_put_fileÚAsyncFileSystem._put_file  r²   r³   c           
   ‹  ó2  "  € \        V\        4      '       d   \        V\        4      '       d   TpTp	EMk\        V\        4      p
V
'       d   \        V4      p\	        4       pVP                  WVR7      p	V
'       dT   V'       d   VeH   V	 Uu. uF1  p\        V4      '       d   K  VP                  V4      '       d   K/  VNK3  	  p	pV	'       g   R# \        V	4      ^8H  p\        V\        4      ;'       d-    \        V4      ;'       g    V P                  V4      G Rj  x€L
 pV P                  V4      pT
;'       dP    \        V4      ;'       d    T;'       g3    \        V4      '       * ;'       d    T;'       d    \        V4      '       * p\        V	VVV
'       * R7      pV	 Uu/ uF#  pV\        P                  P                  V4      bK%  	  pp\        W˜4       UUu. uF  w  ppVV,          '       g   K  VNK  	  ppp\        W˜4       UUu. uF  w  ppVV,          '       d   K  VV3NK  	  ppp\         P"                  ! V Uu. uF  pV P%                  VRR7      NK  	  up!  G Rj  x€L
  T;'       g    V P&                  p. pVP)                  \        V4      4       V F:  w  ppVP+                  V P,                  4      pVP/                  V! VV3/ VB 4       K<  	  \1        VWTR7      G Rj  x€L
 # u upi  ELÝu upi u uppi u uppi u upi  L© L$5i)av  Copy file(s) from local.

Copies a specific file or tree of files (if recursive=True). If rpath
ends with a "/", it will be assumed to be a directory, and target files
will go within.

The put_file method will be called concurrently on a batch of files. The
batch_size option can configure the amount of futures that can be executed
at the same time. If it is -1, then all the files will be uploaded concurrently.
The default can be set for this instance by passing "batch_size" in the
constructor, or for all instances by setting the "gather_batch_size" key
in ``fsspec.config.conf``, falling back to 1/8th of the system limit .
©rœ   rº   Nr»   T©Úexist_ok©r‚   ru   )r1   r¾   r¿   r	   r   Úexpand_pathr
   Úisdirrz   rÀ   rë   r   r   r�   r¢   rÁ   r   r€   Ú	_makedirsr‚   Úset_sizeÚbranch_cororû   Úappendr‹   )r<   rù   rú   rœ   ru   r‚   rº   r6   ÚrpathsÚlpathsrÇ   Úfsrª   rÈ   rÉ   r¼   ÚlÚis_dirÚrÚrdirsÚ
file_pairsÚdr�   ÚlfileÚrfileÚput_files   &&&&&&&,                  r   Ú_putÚAsyncFileSystem._put  s£  é € ô. �eœT×"Ò"¤z°%¼×'>Ò'>ð ˆFØŠFä& u¬cÓ2ˆMßÜ'¨Ó.�Ü Ó"ˆBØ—^‘^ EÈ�^ÓRˆFß§i°8Ò3Gá%+ÓT¡V ´LÀ·Oœ!ÀrÇxÁxÐPQÇ{Ÿ!˜!¡V�ÐTßÙä  ›[¨AÑ-ˆNÜ$ U¬CÓ0÷ ð Ü˜UÓ#×?Ð?¨T¯[©[¸Ó-?×'?ð ð ×(Ñ(¨Ó/ˆEØ"÷ ð Ü˜5Ó!×4Ð4 n÷ Vð VÜ! %Ó(Ô(×TÐT¨[×TÐTÄÈeÓATÔ=Tð ô !ØØØØ)Ô)ô	ˆFñ 06Ó6©v¨!�!”R—W‘W—]‘] 1Ó%Ò%©vˆÐ6Ü" 6Ô2Ô@Ñ2‘t�q˜!°f¸Q·i±i—�Ñ2ˆÑ@Ü),¨VÔ)<ÔNÑ)<¡  AÀFÈ1ÇIÁI”f�q˜!“fÑ)<ˆ
ÑNä�nŠnÉÓOÉÀA˜tŸ~™~¨a¸$˜~Ö?ÉÑOÑP×PÐPØ×2Ð2 4§?¡?ˆ
àˆØ×Ñœ#˜j›/Ô*Û&‰LˆE�5Ø×+Ñ+¨D¯N©NÓ;ˆHØ�L‰L™ %¨Ñ9°&Ñ9Ö:ñ 'ô *Ø˜jô
÷ 
ð 	
ùòE Uò (@ùò 7ùÛ@ùÛNùâOÑPñ
ùsÁ   ‚BLÂLÂK5Â%K5Â>K5Ã0LÃ5LÄLÄK:ÄLÄ<LÅ	LÅLÅ1	LÅ;)LÆ$)K=ÇLÇLÇ6LÇ<LÈLÈ&LÈ.LÉLÉ!LÉ)LÉ*LÉ7A9LË0LË1
LË=LÌLc              ‹  ó   "  € \         h5irO   r­   )r<   rú   rù   r6   s   &&&,r   Ú	_get_fileÚAsyncFileSystem._get_filef  r²   r³   c              ‹  ó.  "  € \        V\        4      '       d   \        V\        4      '       d   TpTpEMu\        V\        4      p	T	;'       d    \        V4      '       * p
V P	                  V4      pV P                  WVR7      G Rj  x€L
 pV	'       d\   V'       d   VeP   V Uu. uF9  p\        V4      '       d   K  V P                  V4      G Rj  x€L
 '       d   K7  VNK;  	  ppV'       g   R# \        V4      p\        V4      ^8H  p\        V\        4      ;'       d-    \        V4      ;'       g    \        4       P                  V4      pT	;'       dB    \        V4      ;'       d    T;'       g%    \        V4      '       * ;'       d    T;'       d    T
p\        VVVV	'       * R7      pV Uu. uF8  p\        P                  ! \        P                  P!                  V4      RR7      NK:  	   pVP#                  RV P$                  4      p. pVP'                  \        V4      4       \)        W‡4       F8  w  r!VP+                  V P,                  4      pVP/                  V! W3/ VB 4       K:  	  \1        VVVR7      G Rj  x€L
 #  ELý EL·u upi u upi  L5i)aÁ  Copy file(s) to local.

Copies a specific file or tree of files (if recursive=True). If lpath
ends with a "/", it will be assumed to be a directory, and target files
will go within. Can submit a list of paths, which may be glob-patterns
and will be expanded.

The get_file method will be called concurrently on a batch of files. The
batch_size option can configure the amount of futures that can be executed
at the same time. If it is -1, then all the files will be uploaded concurrently.
The default can be set for this instance by passing "batch_size" in the
constructor, or for all instances by setting the "gather_batch_size" key
in ``fsspec.config.conf``, falling back to 1/8th of the system limit .
rþ   Nr»   Trÿ   r‚   r  )r1   r¾   r¿   r
   rë   r¨   rÀ   r	   rz   r   r  r   r   r�   Úmakedirsr¢   Údirnamer~   r‚   r  rÁ   r  r  r  r‹   )r<   rú   rù   rœ   ru   rº   r6   r  r	  rÇ   Úsource_not_trailing_seprª   rÈ   rÉ   r¼   Úlpr‚   r�   Úget_files   &&&&&&,            r   Ú_getÚAsyncFileSystem._geti  sL  é € ô. �eœT×"Ò"¤z°%¼×'>Ò'>ð ˆFØŠFä& u¬cÓ2ˆMà&3×&OÐ&O¼LÈÓ<OÔ8OÐ#Ø×(Ñ(¨Ó/ˆEØ×,Ñ,Ø°Xð -ó ÷ ˆF÷ §i°8Ò3Gñ  &óÙ%˜!¬l¸1¯o”AÀtÇ{Á{ÐSTÃ~×AUÓAU—A�A™vð ð ÷ Ùä# EÓ*ˆEÜ  ›[¨AÑ-ˆNÜ$ U¬CÓ0÷ ð Ü˜UÓ#×EÐE¤Ó'8×'>Ñ'>¸uÓ'Eð ð #÷ ð Ü˜5Ó!×4Ð4 n÷ Vð VÜ! %Ó(Ô(×TÐT¨[×TÐTÐ=Tð ô !ØØØØ)Ô)ô	ˆFñ DJÓJÁ6¸RŒ�Š”R—W‘W—_‘_ RÓ(°4×	8Á6ÑJØ—Z‘Z ¨d¯o©oÓ>ˆ
àˆØ×Ñœ#˜f›+Ô&Ü Ö/‰LˆEØ×+Ñ+¨D¯N©NÓ;ˆHØ�L‰L™ %Ñ9°&Ñ9Ö:ñ 0ô *Ø˜j°8ô
÷ 
ð 	
òIò BVùòùò. 	Kñ
ùs’   ‚AJÁ8JÂJÂJÂJÂJÂ#J	Â;J	ÃJ
ÃJ	ÃJ	Ã"AJÄ1"JÅJÅ'	JÅ1JÆ		JÆJÆ.>JÇ,BJÉ>JÉ?JÊJ	Ê	Jc              ƒ  óf   "  €  V P                  V4      G R j  x€L
 R,          R8H  #  L    R# ; i5i)Nr    ÚfileF)rÜ   ©r<   r¢   s   &&r   Ú_isfileÚAsyncFileSystem._isfile²  s2   é € ð	ØŸ*™* TÓ*×*¨FÕ3°vÑ=Ð=Ñ*øð	Úüs    ‚1„) ˜'™) ¦1§) ©.«1c              ƒ  óz   "  €  V P                  V4      G R j  x€L
 R,          R8H  #  L  \         d     R# i ; i5i)Nr    Ú	directoryF)rÜ   ÚOSErrorr#  s   &&r   rÀ   ÚAsyncFileSystem._isdir¸  s:   é € ð	ØŸ*™* TÓ*×*¨FÕ3°{ÑBÐBÑ*øÜô 	Úð	üs(   ‚;„) ˜'™) ¦;§) ©8´;·8¸;c              ƒ  ó`   "  € V P                  V4      G R j  x€L
 P                  RR 4      #  L5i)NrÚ   )rÜ   Úgetr#  s   &&r   Ú_sizeÚAsyncFileSystem._size¾  s'   é € Ø—j‘j Ó&×&×+Ñ+¨F°DÓ9Ð9Ñ&ùs   ‚.—,˜.c              ƒ  óª   "  € T;'       g    V P                   p\        V Uu. uF  q0P                  V4      NK  	  upVR 7      G Rj  x€L
 # u upi  L	5i))r‚   N)r‚   r‹   r,  )r<   rì   r‚   rª   s   &&& r   Ú_sizesÚAsyncFileSystem._sizesÁ  sJ   é € Ø×2Ð2 4§?¡?ˆ
Ü)Ù$)Ó*¡E˜q�Z‰Z˜Ž]¡EÑ*°zô
÷ 
ð 	
ùÚ*ñ
ùs   ‚ A¢A»AÁAÁ
Ac              ‹  ón   "  €  V P                   ! V3/ VB G R j  x€L
  R#  L  \         d     R# i ; i5i)NTF)rÜ   rÃ   r¡   s   &&,r   Ú_existsÚAsyncFileSystem._existsÇ  s:   é € ð	Ø—*’*˜TÑ, VÑ,×,Ð,Ùñ -øä ô 	Úð	üs(   ‚5„# š!›# Ÿ5¡# £2®5±2²5c              ‹  ó   "  € \         h5irO   r­   r¡   s   &&,r   rÜ   ÚAsyncFileSystem._infoÎ  r²   r³   c              ‹  ó   "  € \         h5irO   r­   )r<   r¢   Údetailr6   s   &&&,r   Ú_lsÚAsyncFileSystem._lsÑ  r²   r³   c               óB  "  € Ve   V^8  d   \        R4      hV P                  V4      p/ p/ p/ pVP                  RR4      p V P                  ! V3RR/VB G R j  x€L
 p	T	 Fb  pTR,          P                  R4      pTP                  R^4      R,          pTR,          R	8X  d   YÁ8w  d   YÅT&   Y¶T&   KR  YÁ8X  d   Y·R
&   K^  Y·T&   Kd  	  T'       d	   YT35x € MT\        T4      \        T4      35x € Te   T^,          pT^8  d   R # T F/  pT P                  ! Y^,          3RTRT/TB   R j  x€L
  pT5x € K  	  R #  Lã  \        \
        3 dF   p
TR8X  d   h \        T4      '       d	   T! T
4       T'       d
   T/ / 35x € MT. . 35x €  R p
?
R # R p
?
ii ; i LkDlK•  5i)Númaxdepth must be at least 1r7  FTr¹   rF   Ú/r    r'  rÙ   rº   rY   )ra   rë   r~   r8  rÃ   r(  ÚcallableÚrstripÚrsplitr¾   Ú_walk)r<   r¢   rº   rÄ   r6   Ú	full_dirsÚdirsÚfilesr7  Úlistingrt   ÚinfoÚpathnamerF   r  rf   s   &&&&,           r   r@  ÚAsyncFileSystem._walkÔ  s¼  é € ØÒ H¨q¤LÜÐ:Ó;Ð;à×#Ñ# DÓ)ˆØˆ	ØˆØˆà—‘˜H eÓ,ˆð	Ø ŸHšH TÑA°$ÐA¸&ÑA×AˆGó ˆDð ˜F•|×*Ñ*¨3Ó/ˆHØ—?‘? 3¨Ó*¨2Õ.ˆDØ�F�|˜{Ô*¨xÔ/?à"*˜$‘Ø!�T“
ØÔ!à �b“	à"�d“ñ ÷ Ø˜eÐ#Ô#àœ˜T›
¤D¨£KÐ/Ó/àÒØ˜�MˆHØ˜!Œ|ÙãˆAØŸ:š:Ø•ñØ'/ðØ8>ðØBHò÷ ð �að •ó	 ñK BøÜ!¤7Ð+ô 		Ø˜7Ô"ØÜ˜(×#Ò#Ù˜”ßØ˜B �lÔ"à˜B �lÓ"Ýûð		úñJò ùst   ‚A FÁE ÁD?ÁE Á A/FÃAFÄ*FÄ.FÄ/FÄ2FÄ?E ÅFÅ(FÅ;FÆFÆFÆFÆFÆFc           	   ‹  ó   "  € Ve   V^8  d   \        R4      h^ R Ip\        P                  P                  '       d5   \        P                  P
                  \        P                  P                  3M\        P                  P
                  3pVP                  V4      pV P                  V4      pT;'       g<    TP                  \        ;QJ d    . R V 4       F  NK  	  5M! R V 4       4      4      pVP                  R4      ^ 8¼  d   VP                  R4      M
\        V4      pVP                  R4      ^ 8¼  d   VP                  R4      M
\        V4      p	VP                  R4      ^ 8¼  d   VP                  R4      M
\        V4      p
\        W‰V
4      pVP                  RR4      pVP                  RR	4      p\        V4      '       gU   V P                  ! V3/ VB G R j  x€L
 '       d(   V'       g   V.# YP                  ! V3/ VB G R j  x€L
 /# V'       g   . # / # R
VR V 9   dQ   TpVR V P!                  R
4      pVR V^,            pVV^,           V pW^,           R  P#                  R
4      ^,           pM(RpVR V pW^,           R  P#                  R
4      ^,           pRV9   dD   Ve>   VP                  R4      pVVR  P#                  R
4      ^,           pVV,
          V,           pMR pV'       d   VVR&   V P$                  ! V3RVRVRR	/VB G R j  x€L
 p\'        Y'       d   R
MR,           4      pVP(                  ! V4      p\+        VP-                  4       4       UUu/ uFA  w  ppTP/                  V'       d   VR,          R8X  d
   VR
,           MT4      '       g   K>  VVbKC  	  pppV'       d   V# \1        V4      #  ELà EL· L²u uppi 5i)Nr;  c              3   ó2   "  € T F  qR ,           x € K  	  R# 5i)ú**Nr   )Ú.0Úseps   & r   Ú	<genexpr>Ú(AsyncFileSystem._glob.<locals>.<genexpr>  s   é € Ð-© ˜—*’*«ùs   ‚Ú*Ú?Ú[r7  FÚwithdirsTr<  rÙ   rJ  Úprefixrº   r    r'  )ra   Úrer�   r¢   ÚaltseprL  Úendswithrë   ÚtupleÚfindrz   Úminr~   r   r2  rÜ   ÚrindexÚcountÚ_findr   ÚcompileÚsortedrÔ   Úmatchr¾   )r<   r¢   rº   r6   rT  ÚsepsÚends_with_sepÚappend_slash_to_dirnameÚidx_starÚ	idx_qmarkÚ	idx_braceÚmin_idxr7  rR  Úfirst_wildcard_idxÚrootrS  ÚdepthÚidx_double_starsÚdepth_double_starsÚallpathsÚpatternrª   rE  rí   s   &&&,                     r   Ú_globÚAsyncFileSystem._glob
  sm  é € ØÒ H¨q¤LÜÐ:Ó;Ð;ãä02·±··°”—‘—‘œRŸW™WŸ^™^Ñ,ÄRÇWÁWÇ[Á[ÀNˆØŸ™ dÓ+ˆØ×#Ñ# DÓ)ˆØ"/÷ #
ð #
°4·=±=ßŒEÑ-©Ó-�E‰EÑ-©Ó-Ó-ó4
Ðð &*§Y¡Y¨s£^°qÔ%8�4—9‘9˜S”>¼cÀ$»iˆØ&*§i¡i°£n¸Ô&9�D—I‘I˜c”N¼sÀ4»yˆ	Ø&*§i¡i°£n¸Ô&9�D—I‘I˜c”N¼sÀ4»yˆ	ä�h¨9Ó5ˆà—‘˜H eÓ,ˆØ—:‘:˜j¨$Ó/ˆä˜�ŠØ—\’\ $Ñ1¨&Ñ1×1Ö1ßØ ˜6�Mà ¯
ª
°4Ñ(B¸6Ñ(B×"BÐCÐCçØ�Ià�IØ�D˜˜'�NÔ"Ø!(ÐØ˜8˜G�n×+Ñ+¨CÓ0ˆGØØ�'˜A•+ðˆDð Ø˜!•Ð0ðˆFð  1�˜Ð'×-Ñ-¨cÓ2°QÕ6‰EàˆDØ˜(˜7�^ˆFØ 1�˜Ð'×-Ñ-¨cÓ2°QÕ6ˆEà�4Œ<ØÒ#Ø#'§9¡9¨T£?Ð Ø%)Ð*:Ð*;Ð%<×%BÑ%BÀ3Ó%GÈ!Õ%KÐ"ØÐ 2Õ2°XÕ=‘à�÷ Ø%ˆF�8ÑØŸšØñ
Ø ð
Ø+3ð
Ø<@ð
ØDJñ
÷ 
ˆô ! ¶©À2Õ!FÓGˆØ—*’*˜WÓ%ˆô " (§.¡.Ó"2Ô3ô
á3‘��4Ø�}‰}ç*¨t°F­|¸{Ô/Jð �C–à÷ô ˆAˆtŠGÙ3ð 	ñ 
÷ ØˆJä˜“9Ðòs 2ò #CñB
ùó
ùs€   ‚:O½A9OÂ7OÃDOÇ O Ç!	OÇ+OÇ3OÈOÈOÈCOË2!OÌOÌAOÍ!OÍ< OÎ!OÎ(OÏOÏOÏOc              ‹  óú   "  € / pV P                   ! V3R V/VB G Rj  x€L
  F.  pV P                  V4      G Rj  x€L
 pVR,          WWR,          &   K0  	  V'       d   \        VP                  4       4      # V#  LY L?5i)rº   NrÚ   rF   )r\  rÜ   ÚsumÚvalues)r<   r¢   Útotalrº   r6   ÚsizesÚfrE  s   &&&&,   r   Ú_duÚAsyncFileSystem._du[  sr   é € Øˆà—z’z $ÑD°ÐD¸VÑD×DÒDˆAØŸ™ A›×&ˆDØ"& v¥,ˆE�v•,Óñ E÷ Ü�u—|‘|“~Ó&Ð&àˆLñ EÙ&ùs%   ‚A;�A7žA;¹A9º!A;ÁA;Á9A;c           	   ‹  ó¬  "  € V P                  V4      p/ pVP                  R R4      pV'       dB   VR8w  d;   V P                  V4      G Rj  x€L
 '       d   V P                  V4      G Rj  x€L
 WQ&   V P                  ! W3R R/VB   Rj  x€L
  w  rxp	V'       d   V	P                  V4       TP                  V	P                  4        U
Uu/ uF  w  r«VR,          VbK  	  upp
4       Kc   L� L€ Lbu upp
i DiT'       g%   T P                  T4      G Rj  x€L 
 '       d   / YQ&   \        T4      pT'       g   T# T U
u/ uF  qªYZ,          bK  	  up
# u up
i 5i)r7  FrÙ   NTrF   )	rë   r~   rÀ   rÜ   r@  ÚupdaterÔ   r$  r^  )r<   r¢   rº   rR  r6   rí   r7  rf   rB  rC  rF   rE  Únamess   &&&&,        r   r\  ÚAsyncFileSystem._findf  s$  é € Ø×#Ñ# DÓ)ˆØˆØ—‘˜H eÓ,ˆ÷ ˜ œ
¨T¯[©[¸Ó->×'>Ö'>Ø"Ÿj™j¨Ó.×.ˆC‰Ið %)§J¢J¨tÑ$UÀdÐ$UÈfÒ$U÷ 	Mð 	M‘.�!˜5ßØ—‘˜TÔ"Ø�J‰J¸U¿[¹[¼]ÔK¹]©z¨t˜˜V� dÒ*¹]ÒKÖLñ (?Ù.ñ	Mùó Lð %V÷ ˜dŸl™l¨4Ó0×0×0ð ˆC‰IÜ�s“ˆßØˆLá05Ó6±¨˜#�)’O±Ñ6Ð6ùÒ6ùs~   ‚A	EÁC)Á	EÁEÁ*C+Á+EÂC5Â
C-ÂC5Â<EÃ
C/ÃEÃ+EÃ-C5Ã/EÃ>EÄDÄ
EÄEÄ;EÅEc           
   ƒ  ót  "  € Ve   V^8  d   \        R4      h\        V\        4      '       d   V P                  V.W#4      G R j  x€L
 pEM=\	        4       pV Uu. uF  qPP                  V4      NK  	  ppV EF  p\        V4      '       d…   \	        V P                  WSR7      G R j  x€L
 4      pWF,          pV'       dP   Ve
   V^8:  d   KU  T\	        T P                  \        V4      TVe
   V^,
          MR R7      G R j  x€L
 4      ,          pK™  V'       d-   \	        V P                  WSRR7      G R j  x€L
 4      pWG,          pWT9  g   KÕ  VRJ g"   V P                  V4      G R j  x€L
 '       g   Kü  VP                  V4       EK  	  V'       g   \        V4      h\        V4      #  ELbu upi  EL	 L² L€ LO5i)Nr;  )rº   rþ   T)rº   rR  F)ra   r1   r¿   r¨   r"   rë   r   rn  r¾   r\  r2  r{   rÃ   r^  )r<   r¢   rœ   rº   rí   rª   ÚbitÚrecs   &&&&    r   r¨   ÚAsyncFileSystem._expand_path  sy  é € ØÒ H¨q¤LÜÐ:Ó;Ð;ä�dœC× Ò Ø×)Ñ)¨4¨&°)ÓF×FŠCä“%ˆCÙ59Ó:±T°×(Ñ(¨Ö+±TˆDÐ:Ü�Ü˜Q—<’<Ü D§J¡J¨q JÓ$D×DÓE�CØ•J�Cß ð $Ò/°HÀ´MÙ$ØœsØ"&×"3Ñ"3Ü $ S£	Ø*3Ø9AÒ9M¨°A®ÐSWð #4ó #÷ ó õ ˜ñ ßÜ D§J¡J¨qÈd JÓ$S×SÓT�CØ•J�CØ–< Y°%Ó%7À$Ç,Á,ÈqÃ/×<Q×<QÐ<Qà—G‘G˜A—Jñ/ ÷0 Ü# DÓ)Ð)Ü�c‹{Ðò= Gùò ;ò Eññ Tá<Qùs   ‚AF8ÁF'ÁF8ÁF*Á33F8Â&F/
Â'AF8Ã?F2Ä F8ÄF8Ä3F4
Ä4F8ÅF8Å&F6Å'F8Å3F8ÆF8Æ*F8Æ2F8Æ4F8Æ6F8c              ‹  ó   "  € R # 5irO   r   )r<   r¢   Úcreate_parentsr6   s   &&&,r   Ú_mkdirÚAsyncFileSystem._mkdir¤  ó   é € Ùùó   ‚c              ƒ  ó   "  € R # 5irO   r   )r<   r¢   r   s   &&&r   r  ÚAsyncFileSystem._makedirs§  r„  r…  c              ‹  ó^   "  € R V9  g   VP                  R4      '       d   \        h\        h5i)ÚbÚcompression)r+  ra   r-   )r<   r¢   rÐ   r6   s   &&&,r   Ú
open_asyncÚAsyncFileSystem.open_asyncª  s&   é € Ø�dŒ?˜fŸj™j¨×7Ò7ÜÐÜ!Ð!ùs   ‚-¡-)r“   r’   rŽ   r‚   )FN)FNNN)Ú	overwrite)NN)Fr¹   N)NNrj   rO   )T)Nré   )TN)NF©F)Úrb)-Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú
async_implÚmirror_sync_methodsÚdisable_throttlingr•   Úpropertyr   r£   rŸ   r°   rµ   rÌ   rÑ   rÖ   râ   rå   rî   rö   rû   r   r  r  r  r$  rÀ   r,  r/  r2  rÜ   r8  r@  rn  rv  r\  r¨   r‚  r  r‹  Ú__static_attributes__Ú__classdictcell__Ú__classcell__)r–   Ú__classdict__s   @@r   r�   r�   6  s	  ù‡ € ñð €JØÐØÐð*¨5ð *°tð *È÷ *ð ñó ðò
"ô
ò"ò#ô:ôx"ô
ò&ô4"ôô4'
ôR"ð Ø!ØØôH
òT"ð Ø!ØôG
òRòò:ô
òò"ô"ô4ôlOôb	ô7ô2#ôJô÷"ô "r   r�   c                ó(  € ^ RI Hp \        \        \        4      ,            Fí  pVP                  R4      '       g   K  VR,          p\        P                  V4      '       g   KB  \        P                  ! \        WR4      4      p\        \        WR4      RR4      pV\        WR4      J pV'       g   K‘  V'       g   K›  \        \        W4      V R7      p\        WV4       VP                  '       d   KÑ  \        \        WR4      R	R4      Vn        Kï  	  R# )
a  Populate sync and async methods for obj

For each method will create a sync version if the name refers to an async method
(coroutine) and there is no override in the child class; will create an async
method for the corresponding sync method if there is no implementation.

Uses the methods specified in
- async_methods: the set that an implementation is expected to provide
- default_async_methods: that can be derived from their sync version in
  AbstractFileSystem
- AsyncFileSystem: async-specific default coroutines
)r   rf   :é   NNNFÚ__func__rÙ   )r=   r”  )Úfsspecr   Úasync_methodsÚdirr�   Ú
startswithÚprivater_  r�   rž   ÚgetattrrB   Úsetattrr”  )r=   r   ÚmethodÚsmethodÚiscoÚunsyncÚ
is_defaultÚmths   &       r   r–  r–  °  sÐ   € õ *ä¤#¤oÓ"6×6Ð6ˆØ× Ñ  ×%Ò%ÙØ˜•*ˆÜ�=‰=˜× Ô Ü×.Ò.¬w°sÀDÓ/IÓJˆDÜœW S°5Ó9¸:ÀtÓLˆFØ¤7Ð+=ÈÓ#KÐKˆJß‰tŸ
™
Ü"¤7¨3Ó#7¸SÔA�Ü˜ cÔ*Ø—{—{’{Ü")ÜÐ 2¸TÓBÀIÈró#�C–Kó 7r   c                   ó   € ] tR tRtRtR# )ÚFSSpecCoroutineCanceliÐ  r   N)r�  r‘  r’  r“  r™  r   r   r   r®  r®  Ð  s   † Ûr   r®  Tc                 óZ  € ^ RI p\        P                  P                  \        ^ ,          4       Uu. uF  qUP                  4       '       d   K  VNK  	  ppV '       d   V Uu. uF  qwP                  4       NK  	   pV Uu. uFÊ  pRVP                  P                  P                  RVP                  P                  P                  P                  RVP                  P                  P                  P                  RVP                  P                  P                  RVP                  VP                  P                  4      RV'       d   TMR/NKÌ  	  ppV'       d±   V Fª  pVP                  p	VP!                  4        \        P"                  P$                  P'                  WR4       \        P"                  P$                  P!                  V4       V	 U
u. uF  qª^ ,          ! V4      NK  	   p
 VP                  P)                  V4       K¬  	  V# u upi u upi u upi u up
i   T d     KÎ  i ; i)r   NÚlocalsr"  Ú	firstlineÚlineloÚstackrˆ   )Ú	tracebackr   ÚtasksÚ	all_tasksr   r†   Úprint_stackÚ_coroÚcr_frameÚf_localsÚf_codeÚco_filenameÚco_firstlinenoÚf_linenoÚformat_stackÚ
_callbacksr   ÚfuturesÚFutureÚset_exceptionÚthrow)Úprintoutr   rŠ   Ú	with_taskr´  Útrµ  rˆ   rí   ÚcbsÚcbs   &&&&       r   Ú_dump_running_tasksrÊ  Ô  s«  € ó äŸ™×/Ñ/´°QµÔ8ÓIÑ8�1ÇÁÇ�QˆQÑ8€EÐIßÙ(-Ó.© ×	Ñ	Ö	©Ñ.ñ ó
ñ ˆDð �d—j‘j×)Ñ)×2Ñ2Ø�D—J‘J×'Ñ'×.Ñ.×:Ñ:Ø˜Ÿ™×,Ñ,×3Ñ3×BÑBØ�d—j‘j×)Ñ)×2Ñ2Ø�Y×+Ñ+¨D¯J©J×,?Ñ,?Ó@ØŸI‘D¨4ó	
ñ ð ð 
÷ ÛˆAØ—,‘,ˆCØ�H‰HŒJÜ�O‰O×"Ñ"×0Ñ0°Ô8Ü�O‰O×"Ñ"×)Ñ)¨!Ô,Ù #Ó$¡˜"�ŽU�1ŽX¡Ñ$ðØ—‘—‘˜cÖ"ñ ð €Jùò3 Jùâ.ùò
ùò" %øð ô Úðús6   ±HÁHÁ!HÁ?CHÅ	HÇHÇ*HÈH*È)H*c                   ób   a € ] tR tRt o RR ltR tR tRR ltR tR t	R t
R	 tRR
 ltRtV tR# )ÚAbstractAsyncStreamedFileiõ  c              ƒ  ó®  "  € Vf   RM
\        V4      pV P                  R8w  d   \        R4      hV^ 8  d   V P                  V P                  ,
          pV P
                  '       d   \        R4      hV^ 8X  d   R# V P                  V P                  V P                  V,           4      G Rj  x€L
 pV ;P                  \        V4      ,          un        V#  L(5i)z—
Return data from cache, or fetch pieces as necessary

Parameters
----------
length: int (-1)
    Number of bytes to read; if <0, all remaining bytes.
Nr�  zFile not in read modeúI/O operation on closed file.r   rY   )ÚintrÐ   ra   rÚ   ÚlocÚclosedÚ_fetch_rangerz   )r<   Úlengthrí   s   && r   ÚreadÚAbstractAsyncStreamedFile.readù  s¥   é € ð ’~‘¬3¨v«;ˆØ�9‰9˜ÔÜÐ4Ó5Ð5Ø�AŒ:Ø—Y‘Y §¡Õ)ˆFØ�;�;ˆ;ÜÐ<Ó=Ð=Ø�QŒ;áØ×%Ñ% d§h¡h°·±¸6Õ0AÓB×BˆØ�Š”C˜“HÕ�Øˆ
ñ Cùs   ‚A#CÁ&ACÂ*CÂ+)Cc              ƒ  ó¨  "  € V P                   R9  d   \        R4      hV P                  '       d   \        R4      hV P                  '       d   \        R4      hV P                  P                  V4      pV ;P                  V,          un        V P                  P                  4       V P                  8¼  d   V P                  4       G Rj  x€L
  V#  L5i)z«
Write data to buffer.

Buffer only sent on flush() or if buffer is greater than
or equal to blocksize.

Parameters
----------
data: bytes
    Set of bytes to be written.
zFile not in write moderÎ  z0This file has been force-flushed, can only closeN>   ÚabÚwb)
rÐ   ra   rÑ  ÚforcedÚbufferÚwriterÐ  ÚtellÚ	blocksizeÚflush)r<   Údatarí   s   && r   rÛ  ÚAbstractAsyncStreamedFile.write  sœ   é € ð �9‰9˜LÔ(ÜÐ5Ó6Ð6Ø�;�;ˆ;ÜÐ<Ó=Ð=Ø�;�;ˆ;ÜÐOÓPÐPØ�k‰k×Ñ Ó%ˆØ�Š�C��Ø�;‰;×ÑÓ §¡Ô/Ø—*‘*“,×ÐØˆ
ñ ùs   ‚.C±CÁA;CÃ	CÃ
Cc              ƒ  óÞ  "  € \        V RR4      '       d   R# V P                  '       d   R# V P                  R8X  d	   RV n        M�V P                  '       g   V P                  RR7      G Rj  x€L
  V P                  ed   V P                  P                  V P                  4       V P                  P                  V P                  P                  V P                  4      4       RV n        R#  L~5i)z-Close file

Finalizes writes, discards cache
Ú_unclosableFNr�  T)Úforce)
r¥  rÑ  rÐ   ÚcacherÙ  rÞ  r
  Úinvalidate_cacher¢   Ú_parentr™   s   &r   ÚcloseÚAbstractAsyncStreamedFile.close(  s¤   é € ô
 �4˜¨×.Ò.ÙØ�;�;ˆ;ÙØ�9‰9˜ÔØˆD�Jà—;—;�;Ø—j‘j t�jÓ,×,Ð,à�w‰wÒ"Ø—‘×(Ñ(¨¯©Ô3Ø—‘×(Ñ(¨¯©¯©¸¿¹Ó)CÔDàˆŽñ -ùs   ‚'C-ª,C-ÁC-Á,C+Á-A?C-c              ƒ  ó”  "  € V P                   '       d   \        R 4      hV'       d   V P                  '       d   \        R4      hV'       d   RV n        V P                  R9  d   R# V'       g,   V P                  P                  4       V P                  8  d   R# V P                  f!   ^ V n         V P                  4       G Rj  x€L
  V P                  VR7      G Rj  x€L
 RJdP   V ;P                  V P                  P                  ^ ^4      ,          un        \        P                  ! 4       V n        R# R#  Ls   RT n         h ; i Lh5i)zFlush on closed filez+Force flush cannot be called more than onceTN)ÚfinalF>   r×  rØ  )rÑ  ra   rÙ  rÐ   rÚ  rÜ  rÝ  ÚoffsetÚ_initiate_uploadÚ_upload_chunkÚseekÚioÚBytesIO)r<   rã  s   &&r   rÞ  ÚAbstractAsyncStreamedFile.flush=  sõ   é € Ø�;�;ˆ;ÜÐ3Ó4Ð4ß�T—[—[�[ÜÐJÓKÐKßØˆDŒKà�9‰9˜LÔ(áç˜Ÿ™×)Ñ)Ó+¨d¯n©nÔ<áà�;‰;ÒàˆDŒKðØ×+Ñ+Ó-×-Ð-ð
 ×#Ñ#¨%Ð#Ó0×0¸Ó=Ø�KŠK˜4Ÿ;™;×+Ñ+¨A¨qÓ1Õ1�KÜŸ*š*›,ˆDŽKñ >ñ .øðØ"�”Øúá0ùsS   ‚%E¨EºEÁ!EÁ/A EÂ0D9 ÃD7ÃD9 ÃEÃEÃAEÄ7D9 Ä9
EÅEc              ƒ  ó   "  € V # 5irO   r   r™   s   &r   Ú
__aenter__Ú$AbstractAsyncStreamedFile.__aenter__Z  s
   é € Øˆùr…  c              ƒ  óB   "  € V P                  4       G R j  x€L
  R #  L5irO   )rç  )r<   Úexc_typeÚexc_valÚexc_tbs   &&&&r   Ú	__aexit__Ú#AbstractAsyncStreamedFile.__aexit__]  s   é € Ø�j‰j‹l×Ôùs   ‚–—c              ƒ  ó   "  € \         h5irO   r­   )r<   rK   rà   s   &&&r   rÒ  Ú&AbstractAsyncStreamedFile._fetch_range`  r²   r³   c              ƒ  ó   "  € R # 5irO   r   r™   s   &r   rì  Ú*AbstractAsyncStreamedFile._initiate_uploadc  r„  r…  c              ƒ  ó   "  € \         h5irO   r­   )r<   rê  s   &&r   rí  Ú'AbstractAsyncStreamedFile._upload_chunkf  r²   r³   )rÚ  rä  rÑ  rÙ  rë  N)rY   rŽ  )r�  r‘  r’  r“  rÔ  rÛ  rç  rÞ  ró  rù  rÒ  rì  rí  r™  rš  )rœ  s   @r   rÌ  rÌ  õ  s7   ø‡ € ôò.ò0ô*'ò:òò"ò÷"ò "r   rÌ  rO   rŽ  )r8  rå   r  rû   r£   r°   rÑ   r¨   rÜ   r$  rÀ   r2  r@  rn  r\  rv  r,  r‚  r  )?r   Úasyncio.eventsr@   r�   rï  rÝ   r�   rT  r   Úcollections.abcr   Úglobr   Útypingr   Ú	callbacksr   Ú
exceptionsr   Úimplementations.localr   r	   r
   Úspecr   r   Úutilsr   r   r   r]  r¤  r   r   r   r,   r   r   r'   r9   rB   rM   rQ   ÚhasattrrR   r\   rT   rb   r¥  r(  r`   r]   r[   rg   ro   r‹   r¡  r�   r–  r!   r®  rÊ  rÌ  r   r   r   Ú<module>r     sr  ðÛ Û Û Û Û 	Û Û 	Û 	Û Ý $Ý Ý  å 'Ý &ß QÑ Qß :ß <Ñ <à
�*Š*�WÓ
€Øˆ6€Ø€v€Ø€Ø×+Ñ+Ð òò
ô	ð* Dô *ôZòò$ñ ˆ2Ð!×"Ò"à×ÒÐ'7Õ8÷ Ûà—N‘N�Mð<Ûñ
   ¨'°7Ó;ˆàÐ Ø"Ð ôõ2ð ØØØØôOòf€ô.w	"Ð(ô w	"òtô@	˜Iô 	ð
 ˜$Ð$9ÀUôôBr"Ð 4ö r"øðk ô  ØˆØŠð ús   ÃD8 Ä8EÅE