7ThSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK JrJr SSKJr SSKJr SSKJrJrJr SS KJrJr SS KJrJrJr \R>"S 5r S/r!S/r"Sq#\RHr$S r%S r&S)Sjr'SS.Sjr(S)Sjr)\ S5r*Sr+Sr,\-"\S5(a\R\"\,S9 \(aSSK/r/\/R`r1OSSK/r/\2"\/S\35r1Sr5Sr6S*Sjr7S\84Sjr9S\SSS4Sjr:/SQr;"S S!\5r5r?S%S%\?S4S&jr@"S'S(\5rAg!\4a Sr/\3r1NXf=f)+N)contextmanager) has_magic) TYPE_CHECKINGIterable)DEFAULT_CALLBACK)FSTimeoutError)LocalFileSystemmake_path_posix trailing_sep)AbstractBufferedFileAbstractFileSystem)glob_translate is_exception other_pathsz_[^_]cN[(d[R"5q[$)zwAllocate or return a threading lock. The lock is allocated on first use to allow setting one lock per forked process. )_lock threadingLockC/var/www/auris/envauris/lib/python3.13/site-packages/fsspec/asyn.pyget_lockrs 5  Lrc,S[S'S[S'Sqg)zReset 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. Nr)iothreadlooprrrr reset_lockr&sHQKDG Erc# U(aUOSnUb[R"XS9nUIShvN US'UR5 gN![anXBS'SnAN&SnAff=f!UR5 f=f7f)Ntimeoutr)asynciowait_for Exceptionset)eventcororesultr exs r_runnerr)3sf gdG6Jq    q   sI#A6AAAA6A AAA!AA!!A33A6rcVU(aUOSnUbUR5(a [S5e[RR 5nXPLa [ S5eU"U0UD6nS/n[ R"5n[R"[XXr5U5 URS5(aOUbUS-nUS:a[eM-USn [U [R5(a[U e[U [5(aU eU $![ a e[a Nf=f)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) NzLoop is not runningz)Calling sync() from within a running looprr) is_closed RuntimeErrorr!eventsget_running_loopNotImplementedErrorrEventrun_coroutine_threadsafer)waitr isinstance TimeoutError BaseException) rfuncr argskwargsloop0r&r'r% return_results rsyncr;?s&!gdG |t~~''011 //1 =%&QR R    DVF OO E $$WU&%JDQ  ::a==    qLG{$$ 1IM-!5!566-/ M= 1 11     s-DD('D(cJ^^[R"T5UU4Sj5nU$)zGiven 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. cT>T=(d USn[URT/UQ70UD6$Nr)r;r)r7r8selfr6objs rwrappersync_wrapper..wrapperss+~d1gDIIt5d5f55r) functoolswraps)r6r@rAs`` r sync_wrapperrEls'__T66 Nrc#F# [R"5n[RS:Xa>[ [S5(a)[R "[R "55 Sv [R "U5 g![R "U5 f=f7f)NntWindowsSelectorEventLoopPolicy)r!get_event_loop_policyosnamehasattrset_event_loop_policyrH)original_policys r_selector_policyrO{sf335O7 77d?ww0PQQ  ) )'*P*P*R S %%o6%%o6sB!AB/B!BB!c[Sc[5 [Scu[5 [R"5[S'SSS5 [ R "[SRSS9nSUlUR5 U[S'SSS5 [S$[S$!,(df  Nn=f!,(df  [S$=f)z\Create or return the default fsspec IO loop The loop will be running on a separate thread. rNfsspecIO)targetrKT) rrrOr!new_event_looprThread run_foreverdaemonstartr)ths rget_looprYs  Aw ZAw%'%446DG(%%T!W-@-@zR      7N47N (' Z 7Ns#CB/AC/ B= 9C Cc,S[S'S[S'Sqgr>)rrlockrrrreset_after_forkr\sDGHQK Drregister_at_fork)after_in_childerroriFcBSSKJn U(a SU;aUS$O SU;aUS$U(a[$[c[$[R "[R 5up#U[R:XagUS-$![[[4a [s$f=f)Nr)confnofiles_gather_batch_sizegather_batch_size) fsspec.configrb_NOFILES_DEFAULT_BATCH_SIZEresource_DEFAULT_BATCH_SIZE getrlimit RLIMIT_NOFILE ImportError ValueError ResourceError RLIM_INFINITY)nofilesrb soft_limit_s r_get_batch_sizerts" &$ .34 4 / $ &+, ,**""# **8+A+AB X+++Q ] 3#""#s&BBBreturncP[R"5 g![a gf=f)z Being executed by an event loop?TF)r!r.r,rrr running_asyncrws(  " s  %%cl^^^# Uc [US9nUS:Xa [U5nUS:deUUU4SjnSn[U5nS/U-n [5n U (dXx:a[U 5U:aNXx:aIU R[R "U"XU555 US- n[U 5U:aXx:aMIU (dU $[R "U [RS9IShvN upU (a'U R5IShvN upXU 'U (aM'U (aMXx:aMU $NFN'7f)aRun 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)rqrerc># [R"UTS9IShvN U4TRS5 $N![a&nT(deX!4sSnATRS5 $SnAff=f!TRS5 f=f7f)Nrr)r!r"relative_updater#)r&iecallbackreturn_exceptionsr s r _run_coro'_run_coros_in_chunks.._run_corost ( ))$@@!C  $ $Q ' A $4K  $ $Q '    $ $Q 'sOB757B7 A' A" A' A*B"A''A**A==Br) return_when) rtlenr$addr! ensure_futurer2FIRST_COMPLETEDpop)coros batch_sizer}r r~rqrr{nresultspendingdoner'ks ``` r_run_coros_in_chunksrs<$W5 RZ >>( A E AfqjGeG QU'lZ'AE KK--i!.DE F FA'lZ'AE  N &ll7@W@WXX "hhj(IFAJd 'QU N Y(s<B2D490D4)D0* D4 D2 D4D4'D4.D42D4)_ls _cat_file _get_file _put_file_rm_file_cp_file _pipe_file _expand_path_info_isfile_isdir_exists_walk_glob_find_du_size_mkdir _makedirscv^\rSrSrSrSrSrSrSSSS.U4Sjjr\ S5r S r S(S jr S r S rS)S jrS*SjrS+SjrSrS+SjrS,SjrS-SjrS*SjrS\SS4SjrSrS\S4SjrSrSrSrS.SjrSrSr S/Sjr!S0Sjr"S.S jr#S1S!jr$S2S"jr%S(S#jr&S/S$jr'S3S%jr(S4S&jr)S'r*U=r+$)5AsyncFileSystemi6aWAsync 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. TFN) asynchronousrrc>Xl[R"5UlU(dU=(d [ 5UlOSUlX0l[TU] "U0UD6 gN) rrJgetpid_pidrY_looprsuper__init__)r?rrrr7r8 __class__s rrAsyncFileSystem.__init__GsE(IIK +DJDJ$ $)&)rcvUR[R"5:wa [S5eUR$)NzThis class is not fork-safe)rrJrr,rr?s rrAsyncFileSystem.loopQs* 99 #<= =zzrc# [e7frr/r?pathr8s rrAsyncFileSystem._rm_fileW !! c # U=(d URnURXS9IShvN n[[U5Vs/sHoPR"U40UD6PM snUSS9IShvN $NAs snfN 7f)N recursiveTrrq)rrrreversedr)r?rrrr8ps r_rmAsyncFileSystem._rmZsq24?? &&t&AA)19$ @A]]1 ' ' @!   B @ s-(A5A,A5A. A5'A3(A5.A5c# [e7frr)r?path1path2r8s rrAsyncFileSystem._cp_filedrrcx# URX5IShvN URU5IShvN gNN7fr)rr)r?rrs r_mv_fileAsyncFileSystem._mv_filegs1mmE)))mmE""" *"s:6:8::c N# Uc U(aSnOUcSn[U[5(a[U[5(aUnUn GO:[U[5n URXUS9IShvN nU (aVU(aUbLUV s/sH7n [ U 5(aMUR U 5IShvN (aM5U PM9 nn U(dg[ U5S:Hn [U[5=(a+ [ U5=(d UR U5IShvN n U =(aK [U5=(a U =(d0 [U5(+=(a U =(a [ U5(+n[UUUU (+S9n U=(d URn[X5VVs/sHunnUR"UU40UD6PM nnn[UUSSS9IShvN n[[U5H nUS:Xa[U[5(aM Ue gGNGNds sn fGNs snnfNM7f)Nignoreraise)maxdepthrrexistsflattenT)rr~rq)r3liststrrr rrrrrziprrfilterrFileNotFoundError)r?rrron_errorrrr8paths1paths2 source_is_strrsource_is_file dest_is_dirrp1p2rr'r(s r_copyAsyncFileSystem._copyks   H  H eT " "z%'>'>FF&uc2M,,I-Fi83G &%!l1oAt{{ST~AUAUAv [A-N$UC0U#?T[[-?'? #5!4nV!%((T[TeAT=T !)) F 24?? ?B6?RS?RVRr200?RS+ jD$  v.B8# 27H(I(IH/C BV(@T snA&H%(H)H%HH.H /H:HAH%HB H%"!HH%H#:H%HH%H%c# [e7frr)r?rvaluemoder8s rrAsyncFileSystem._pipe_filerrc # [U[5(aX0nU=(d URn[UR 5VVs/sHupVUR "XV40UD6PM snnUSS9IShvN $s snnfN 7f)NTr)r3rrritemsr)r?rrrr8rvs r_pipeAsyncFileSystem._pipeso dC =D24?? )9= FT__Q ,V , F!   F sAA?A7 ' A?2A=3 A?c|# SnSnUb;US:a5UcU*nSnSnO/U=(d URU5IShvN SnXB-nOUcSnU(d_Ub3US:a-Ub)U=(d URU5IShvN SnXC-nOUcSn[U[R5(aUS-nSUS U3$NN?7f) z"Helper for "Range"-based _cat_fileNFrTsizerzbytes=-)rr3numbersIntegral)r?urlrWendrsuffs r_process_limitsAsyncFileSystem._process_limitss  {f>djjo 5v>  ]E37$B$**S/$96#BD*C#w//00qwau%%!6%:s"6B<B8AB<:B:;>B<:B<c# [e7frr)r?rrWrr8s rrAsyncFileSystem._cat_filerrc.# URXS9IShvN nUVs/sHoR"U40UD6PM nnU=(d URn[XtSSS9IShvN nUS:Xa#[ [ [ U5S5n U (aU e[U5S:d-[W[5(dUSURU5:wa8[Xh5V V s0sHupUS:wd[ U 5(aMX_M! sn n $US$Ns snfNs sn n f7f) NrTrrqr~rFrromit) rrrrnextrrrr3r_strip_protocolr) r?rrrrr8pathsroutr(rrs r_catAsyncFileSystem._cats '''BBD ? D c# [e7frr)r?lpathrpathrr8s rrAsyncFileSystem._put_filerrc # [U[5(a[U[5(aUnUn GOW[U[5n U (a [U5n[ 5n U R XUS9n U (aNU(aUbDU V s/sH/n [ U 5(aMU RU 5(aM-U PM1 n n U (dg[U 5S:Hn [U[5=(a+ [ U5=(d URU5IShvN nURU5nU =(aK [U5=(a U =(d0 [U5(+=(a U=(a [ U5(+n[U UUU (+S9nU Vs0sH#nU[RRU5_M% nn[X5VVs/sHunnUU(dMUPM nnn[X5VVs/sHunnUU(aMUU4PM nnn[ R""UVs/sHnUR%USS9PM sn6IShvN U=(d UR&n/nUR)[U55 UH:unnUR+UR,5nUR/U"UU40UD65 M< [1UXTS9IShvN $s sn fGNs snfs snnfs snnfs snfNN$7f)avCopy 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 . rrNrrTexist_okrr})r3rrr r expand_pathr isdirrrrrrrJrrr!gatherrrset_size branch_cororappendr)r?rrrr}rrr8rpathslpathsrfsrrrrlis_dirrrdirs file_pairsdrlfilerfileput_files r_putAsyncFileSystem._puts|. eT " "z%'>'>FF&uc2M'. "B^^E^RFi83G%+TVLO!rxxPQ{!VT [A-N$UC0U#?T[[-?'? ((/E"5!4nV!%((T[TeAT=T !)) F066v!!RWW]]1%%v6"62@2tq!fQi2@),V)<N)<AF1Ifq!f)< NnnOAt~~a$~?OPPP24?? #j/*&LE5++DNN;H LL%9&9 :'* j   EU (@7@NOP sBK3KK4K:AK3KA>K3*K8K3KK#K34K$ K$K3(K*K3 K/ BK3 K1 K3K31K3c# [e7frr)r?rrr8s rrAsyncFileSystem._get_filearrc# [U[5(a[U[5(aUnUnGOa[U[5n U =(a [U5(+n UR U5nUR XUS9IShvN nU (aVU(aUbLUV s/sH7n [U 5(aMUR U 5IShvN (aM5U PM9 nn U(dg[U5n[U5S:Hn [U[5=(a+ [U5=(d [5RU5n U =(a= [U5=(a U =(d" [U5(+=(a U =(a U n[UUUU (+S9nUVs/sH5n[R"[RR!U5SS9PM7 nUR#SUR$5n/nUR'[U55 [)X5H8up!UR+UR,5nUR/U"X40UD65 M: [1UUUS9IShvN $GNGNs sn fs snfN7f) aCopy 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 NrrTr rr )r3rrr rrrr rr rrrrJmakedirsrdirnamerrrrrrrr)r?rrrr}rr8rrrsource_not_trailing_seprrrrlprrget_files r_getAsyncFileSystem._getds+. eT " "z%'>'>FF&uc2M&3&OL'>u'E #5!4nV!%((T[T=T !)) FDJJ6RRWW__R(4 86JZZ doo> #f+&/LE++DNN;H LL%9&9 :0* j8   I BV. K s\A>I:I(I:I.2I.I+ I.I.CI:E9D DD B-E9 E6E4E6 E9D E107E,'E9,E11E94E66E9c# UbUS:a [S5eSSKn[RR(a4[RR [RR4O[RR 4nUR U5nURU5nU=(d! UR [SU555nURS5S:aURS5O [U5nURS5S:aURS5O [U5n URS5S:aURS5O [U5n [XU 5n URSS 5n [U5(dQUR"U40UD6IShvN (a&U (dU/$XR"U40UD6IShvN 0$U (d/$0$S USU ;a6USU R!S 5n USU S-n XS-SR#S 5S-nOS n XS-SR#S 5S-nS U;a5Ub0URS 5nXSR#S 5S-nUU- U-nOSnUR$"U 4US S S.UD6IShvN n['X(aS OS -5nUR("U5n[+UR-55VVs0sH6unnUR/U(aUSS:XaUS -OU5(dM3UU_M8 nnnU (aU$[1U5$GNGN`Ns snnf7f)NrrBrc3*# UH oS-v M g7f)**Nr).0seps r (AsyncFileSystem._glob..s-*s*?[r?FrCrrPT)rwithdirsr?r,r1)rnrerJraltseprRendswithrtuplefindrminrrrrrindexcountrrcompilesortedrmatchr)r?rrr8rYseps ends_with_sepappend_slash_to_dirnameidx_star idx_qmark idx_bracemin_idxr?rootdepthidx_double_starsdepth_double_starsallpathspatternrrKrs rrAsyncFileSystem._globs  HqL:; ;02 RWW^^,RWW[[N d+ ##D)"/# 4== -- -4 &*YYs^q%8499S>c$i&*iin&9DIIcNs4y &*iin&9DIIcNs4y h95He,\\$1&111 6M 4(B6(B"BCCII D'N "8Gn++C0G 'A+&D1'--c2Q6ED1'--c2Q6E 4<##'99T? %)*;%<%B%B3%G!%K" 22X=   4 @F  ! 2!FG**W%"(.."23 34}}*tF|{/JC AtG3   J9 ]2#C,  sPF*M,L3-)ML6B?ML9AM2L;L;M6M9M;Mc# 0nUR"U4SU0UD6IShvN H&nURU5IShvN nUSXWS'M( U(a[UR55$U$NPN67f)NrrrK)rrsumvalues)r?rtotalrr8sizesfrKs rrAsyncFileSystem._duJsrzz$DDVDDDAA&D"&v,Ev, E u||~& &L E&sA2A.A2A05A20A2c # URU5n0nURSS5nU(a?US:wa9URU5IShvN (aURU5IShvN XQ'UR"X4SS0UD6ShvN upxn U(aU R U5 UR U R 5V V s0sH upU SU _M sn n 5 M^NN{N]s sn n f U(d#URU5IShvN (a0XQ'[U5n U(dU $U V s0sHoXZ_M sn $s sn f7f)Nr?FrTrK) rrrrrupdaterrrb) r?rrrXr8rr?rsrHrIrKrKnamess rrAsyncFileSystem._findUs##D)He,  T[[->'>'>"jj..CI%)JJt$Ud$Uf$U M.!5 T" JJU[[]K]ztV d*]K L(?. ML%Vdll4000CIs L056#)O6 66slAE C! E'C#(EC-C%C- :EC'  E#E%C-'"E D  &E0E>Ec $# UbUS:a [S5e[U[5(aURU/X#5IShvN nGO[ 5nUVs/sHoPR U5PM nnUHn[ U5(an[ URXSS9IShvN 5nXF-nU(aAUbUS::aMIU[ UR[U5UUbUS- OSS9IShvN 5-nMU(a%[ URXSSS9IShvN 5nXG-nXT;dMUSLd URU5IShvN (dMURU5 M U(d [U5e[U5$GN>s snfNNNvNK7f)NrrB)rr T)rrXF)rnr3rrr$rrrrrrrrrb)r?rrrrrbitrecs rrAsyncFileSystem._expand_pathnsv  HqL:; ; dC ))4&)FFC%C59:T((+TD:Q<<DJJqJ$DDECJC $/HM$s"&"3"3 $S *39A9MASW#4# DJJqdJ$SSTCJC' R"!H T"! G R  : ""4lCJ 72#J  ""rrcSSKJn [[[5-HnUR S5(dMUSSn[ RU5(dM<[R"[XS55n[[XS5SS5nU[XS5LnU(dMU(dM[[X5US 9n[XU5 UR(aM[[XS5S S5Ul M g) aPopulate 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)rrsrNF__func__r)r@r)fsspecr async_methodsdirr startswithprivatercinspectiscoroutinefunctiongetattrrEsetattrr)r@rmethodsmethodiscounsync is_defaultmths rrrs*#o"66  %% * == ..wsD/IJDWS59:tLF7+=#KKJt "73#7SAc*{{{") 2TBIr#CK7rc\rSrSrSrg)FSSpecCoroutineCancelirN)rrrrrrrrrrsrrTc >SSKn[RR[S5Vs/sHoUR 5(aMUPM nnU(aUVs/sHowR 5PM nUVs/sHnURRRURRRRURRRRURRRURURR5U(aUOSS.PM nnU(aUHnURn UR!5 [R"R$R'XR5 [R"R$R!U5 U V s/sH oS"U5PM n URR)U5 M U$s snfs snfs snfs sn f!Ua Mf=f)Nr)localsr- firstlinelinelostacktask) tracebackr!tasks all_tasksrr print_stack_corocr_framef_localsf_code co_filenameco_firstlinenof_lineno format_stack _callbackscancelfuturesFuture set_exceptionthrow) printoutrexc with_taskrtrrrcbscbs r_dump_running_tasksrs //Q8 I81Q8E I(-.   . Djj))22JJ''..::,,33BBjj))22++DJJ,?,?@%D4   A,,C HHJ OO " " 0 0 8 OO " " ) )! , # $"U1X $  c" J3 J. " %  s0G> G>H;C HH HHHcV\rSrSrS SjrSrSrSSjrSrSr Sr S r SS jr S r g )AbstractAsyncStreamedFileic# UcSO [U5nURS:wa [S5eUS:aURUR- nUR (a [S5eUS:XagUR URURU-5IShvN nU=R[U5- slU$N$7f)z Return data from cache, or fetch pieces as necessary Parameters ---------- length: int (-1) Number of bytes to read; if <0, all remaining bytes. NrerzFile not in read moderI/O operation on closed file.r)intrrnrlocclosed _fetch_ranger)r?lengthrs rreadAbstractAsyncStreamedFile.reads~3v; 99 45 5 A:YY)F ;;<= = Q;%%dhh60ABB CH CsBCC%Cc# URS;a [S5eUR(a [S5eUR(a [S5eURR U5nU=R U- slURR5UR:aUR5IShvN U$N7f)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. >abwbzFile not in write moderz0This file has been force-flushed, can only closeN) rrnrforcedbufferwritertell blocksizeflush)r?datars rrAbstractAsyncStreamedFile.writes 99L (56 6 ;;<= = ;;OP Pkk% C ;;    /**,    sB?C CC c# [USS5(agUR(agURS:XaSUlOUR(dUR SS9IShvN UR bcUR RUR5 UR RUR RUR55 SUlgN|7f)z-Close file Finalizes writes, discards cache _unclosableFNrT)force) rrrcacherrrinvalidate_cacher_parentrs rcloseAbstractAsyncStreamedFile.closes 4 . .  ;;  99 DJ;;jjtj,,,ww"((3(()CD -sA!C"#C $A=C"cl# UR(a [S5eU(aUR(a [S5eU(aSUlURS;agU(d)URR 5UR :agURc SUlUR5IShvN URUS9IShvN SLaJU=RURRSS5- sl[R"5UlggNi! SUle=fNa7f) NzFlush on closed filez+Force flush cannot be called more than onceT>rrr)finalF) rrnrrrrroffset_initiate_upload _upload_chunkseekioBytesIO)r?rs rrAbstractAsyncStreamedFile.flush,s ;;34 4 T[[JK K DK 99L ( ))+dnn<  ;; DK ++--- ##%#0 0 = KK4;;++Aq1 1K**,DK > . "  0s=B#D4&D%9D#:D%>D4D2AD4#D%% D//D4c# U$7frrrs r __aenter__$AbstractAsyncStreamedFile.__aenter__Is  sc@# UR5IShvN gN7fr)r)r?exc_typeexc_valexc_tbs r __aexit__#AbstractAsyncStreamedFile.__aexit__Lsjjls c# [e7frr)r?rWrs rr&AbstractAsyncStreamedFile._fetch_rangeOrrc # g7frrrs rr*AbstractAsyncStreamedFile._initiate_uploadRrrc# [e7frr)r?rs rr'AbstractAsyncStreamedFile._upload_chunkUrr)rrrrrN)rer)rrrrrrrrrrrrrrrrrrrs/.0*':" "rrrr)Br!asyncio.eventsrCrrrrJrYr contextlibrglobrtypingrr callbacksr exceptionsr implementations.localr r r specr rutilsrrrrarrrrr.rrr)r;rErOrYr\rLr]rir_rorr2rmrjrhrtboolrwrrrrr#rrrrrrrs  %*'&QQ:<< **W  6 v ++  %)*Z 77& 2!""'78NNM<  '7; "2t    BL .f "(f "R@ I $$9UBr" 4r"o    s#D== E  E