"hddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl Z ddl ZddlmZddlmZddlmZmZmZddlmZmZmZej8d ZGd d eZd Z d Z!dZ"GddejFjHZ%GddejFjLZ'dZ(GddejFjRZ*GddeZ+y#e$r e sddlZYwxYw)N) lru_cache) TYPE_CHECKING)AsyncFileSystem)_DEFAULT_CALLBACK) filesystemopensplit_protocol) isfilelikemerge_offset_ranges other_pathszfsspec.referencec$eZdZfdZdZxZS)ReferenceNotReachablec:t||||_||_yN)super__init__ referencetarget)selfrrargs __class__s ]/var/www/html/sandstorm/venv/lib/python3.12/site-packages/fsspec/implementations/reference.pyrzReferenceNotReachable.__init__s $" c:d|jd|jS)Nz Reference "z" failed to fetch target )rrrs r__str__zReferenceNotReachable.__str__!sT^^,,Edkk]SSr)__name__ __module__ __qualname__rr __classcell__rs@rrrs Trrc:t|jdSNr)listvalues)ds r_firstr(%s  A rc|j|}t|ttfr|drt |ddS|dSyr$)get isinstancer%tupler )path referencesrefs r_prot_in_referencesr0)sF .. C#e}%,/F~c!f%a(>A>&rct|trt|||giSi}|D]/}t||}|j|gj |1|Sr)r+strr0 setdefaultappend)pathsr.outr-protocols r_protocol_groupsr8/s`%#E:6@@ C2&tZ8 x$++D12 JrceZdZdZy)RefsValuesViewc#K|jjjD]'}tj|j )|jj jEd{|jjD]c}|jj|}t|dk(r|j|dzA|jj|Ed{ey77 w)Nr/0) _mapping zmetadatar&jsondumpsencode_itemslistdir_get_chunk_sizeslen_generate_all_records)rvalfield chunk_sizess r__iter__zRefsValuesView.__iter__:s==**113 +C**S/((* * +==''..000]]**, BE--88?K;1$mmEDL11}}::5A A A  B 1 Bs%A6D8C>9A=D6D7DDNrrr rJrrr:r:9s Brr:ceZdZdZy) RefsItemsViewczt|jj|jjSr)zipr=keysr&rs rrJzRefsItemsView.__iter__Gs)4==%%')=)=)?@@rNrKrLrrrNrNFsArrNchd}d}t|ddd|dddD]\}}|||zz }||z}|S)Nr)rP)idxsizesrGmultiss rravel_multi_indexrZKsS C DC"IuTrT{+1 q4x   JrceZdZdZedZedZ ddZedZ ddZ ddZ d Z e d d Zd Zd ZdZdZdZdZe ddZdZedZdZd dZd dZdZdZdZdZy)!LazyReferenceMapperaoThis interface can be used to read/write references from Parquet stores. It is not intended for other types of references. It can be used with Kerchunk's MultiZarrToZarr method to combine references into a parquet store. Examples of this use-case can be found here: https://fsspec.github.io/kerchunk/advanced.html?highlight=parquet#parquet-storagecddl}|Sr$)numpy)rnps rr_zLazyReferenceMapper.np]s  rcddl}|Sr$)pandas)rpds rrbzLazyReferenceMapper.pdcs  rNc|_i_i_d_|t j dn|_j jdjjdgjd<tjjd}|d_ |d_ jdz_ |xs j_|_t!|fd }|_y) a Parameters ---------- root : str Root of parquet store fs : fsspec.AbstractFileSystem fsspec filesystem object, default is local filesystem. cache_size : int, default=128 Maximum size of LRU cache, where cache_size*record_size denotes the total number of references that can be loaded in memory at once. categorical_threshold : int Encode urls as pandas.Categorical to reduce memory footprint if the ratio of the number of unique urls to total number of refs for each variable is greater than or equal to this number. (default 10) Nfile/ .zmetadata record_sizemetadataz/{field}/refs.{record}.parq)maxsizec0jj||}tjjj |}j j|d}|jDcic]}|||j}}|Scc}w)zcached parquet file loader)rHrecord fastparquet)engine) urlformatioBytesIOfscat_filerb read_parquetcolumnsr&)rHrkr-datadfcrefsrs r open_refsz/LazyReferenceMapper.__init__..open_refss~88??v?>D::dgg..t45D%%d=%AB-/ZZ8Ar!u||O8D8K9s8B)rootrIrBdirsfsspecrrrrsjoinr?loadsrgr>rnout_root cat_threshrrz)rr{rrr cache_sizecategorical_thresholdmetrzs` rrzLazyReferenceMapper.__init__is(   /1z&##F+r$(GG$4$4 HHdii. /%  L!jj\23}-Z99<< -DII / : &  ' #rc i|d}|jdj|dgtj|j t ||fi|S)Nrhrgrerf)piper~r?r@rAr\)rgr{rrkwargsrs rcreatezLazyReferenceMapper.createsKk: $ -. 30F0F0HI"46v66rc\|jV|jDcgc]}|jddd}}|Dchc]}|s|jdr|c}|_|j}|r,|Dcgc]!}tj j |#}}|Scc}wcc}wcc}w)zList top-level directoriesrerSr.)r|r>split startswithosr-basename)rrpr|listingr-s rrCzLazyReferenceMapper.listdirs 99 04?1AGGCOA&?D?$(HqAall36GHDI)) :AB$rww''-BGB @HCsBB$B$B$5&B)c |s|j}tdg|jDcgc] }d|vs| c}z|jDcgc] }d|vs| c}z}|dur|j |t |S|Dcgc]}|ddd }}|Dcgc]N}|dt ||jvr"tj|j|n|j|dP}}t ||zd S|jdd }t |d kDr td |d} t|jDcgc]}|j|ds|c}|jDcgc]}|j|ds|c}z}|Dcgc]N}|dt ||jvr"tj|j|n|j|dP}}|j| } |durt|t| zS|j| } t| | D cgc]\}} | dr |d| d d} }} || zScc}wcc}wcc}wcc}wcc}wcc}wcc}wcc} }w) zShortcut file listingsrfreF directoryrnametypesizerdc |dS)NrrL)rYs rz(LazyReferenceMapper.ls..s AfIrkeyrSz(Cannot list within directories right nowrT)rCsetr>rBupdatesortedrEr?r@rFileNotFoundErrorr_keys_in_fieldr%rFrP)rr-detaildirnamesrothersdirinfofileinfopartsrHrQrecsrecrecinfos rlszLazyReferenceMapper.lss||~H$(NNFDco4FG$(KKCD3d?4CDF  h'f~%KSCG{A>G# !"4>>1 4>>$#78![[. H 'H,2EF F 3" u:>#$NO Oa"nn Ld4& 0KT L $ Kt$qz/JtK L   t~~-JJt~~d34T*     ""5) U?<$t*, ,))%0!t_ c1v63r7 ;  '!!iGC  $ MK  " sH I I  I I  I#AI(?I-I--I2 I2 AI79I<c||jvr|j|S||jvr0tj|j|j Sd|vs|j |r t ||jd\}}|j|\}}}|jj||fij|d}|t |r|S |j|\}}}|dk(ry|j||} gd} | D cgc]} | | vr| | |nd} } | d} | | S| d t d| d d ddgk(r| dd S| dd S#tttf$r t |wxYwcc} w) zfGet the reference for one key Returns bytes, one-element list or three-element list. reFNrrr-offsetrrawrTzThis reference has been deletedrS)rBr>r?r@rA_is_metaKeyErrorr_key_to_recordr*rz ValueError TypeErrorr)rrrHsub_keyrk_mayberi chunk_sizeryrurx selectionrs r _load_one_keyz!LazyReferenceMapper._load_one_keys $++ ;;s# # DNN "::dnnS1299; ; ^t}}S13- 3w**3/ 1  b155guE =N L %)%8%8%= "FB Q>>%0D4AHIAAIT!WR[47I Im ?J Q< <= = Qq>aV #Ra= !}I'89 3-  Js E;EE< E9ic2|jd\}}|j|}t|dk(ry|jdDcgc] }t|}}t ||}||j z}||j z} || t|fScc}w)z3Details needed to construct a reference for one keyrer)rrrr)rrDrEintrZrg) rrrHchunkrIrx chunk_idx chunk_numberrkrs rrz"LazyReferenceMapper._key_to_record syy~ u++E2 { q %*[[%56SV6 6(K@ !1!11 D,, ,r3{+++ 7sBc||jvr[|j|d}t|d|dDcgc]\}}tj||z }}}||j|<|j|Scc}}w)z6The number of chunks along each axis for a given fieldz/.zarrayshapechunks)rIr>rPmathceil)rrHzarrayrYrx size_ratios rrDz$LazyReferenceMapper._get_chunk_sizess (( (^^ugX$67F-0&BR-S%)Q !a% J'1D  U #&& s"A9c|j||}tt|j}t |dk(r d|DSt |dk(r|dSd|DS)z8The references for a given parquet file of a given fieldrc32K|]}t|ywrr%.0ts r z7LazyReferenceMapper._generate_record..*s(DG(rSrc3LK|]}|dst|ddn|dyw)rNrrs rrz7LazyReferenceMapper._generate_record..0s)B!qtD2AK15Bs"$)rziterrPr&rE)rrHrkryits r_generate_recordz$LazyReferenceMapper._generate_record$s`~~eV, #dkkm$ % t9>(R( ( Y!^; CrB Brc#Kd}|j|D]}||z} tj||jz }t |D]}|j ||Ed{y7w)zJLoad all the references within a field by iterating over the parquet filesrSN)rDrrrgranger)rrHnrecchrks rrFz)LazyReferenceMapper._generate_all_records2ss''. B BJD yy 0 001Dk s T""rct|Sr)idrs r__hash__zLazyReferenceMapper.__hash__As $xrc$|j|Sr)r)rrs r __getitem__zLazyReferenceMapper.__getitem__Ds!!#&&rcd|vr|j|sx|jd\}}|j|\}}}|jj ||fi}|||<t ||j k(r|j||yy||j|<tjt|tr|jn||j|<yNre)rrrrBr3rErgwriter?rr+bytesdecoder>) rrvaluerHrrkrXrsubdicts r __setitem__zLazyReferenceMapper.__setitem__Hs #:dmmC099S>LE5..s3LFAqkk,,eV_bAGGAJ7|t/// 5&)0 %DKK "&**",UE": #DNN3 rc0|jdxsd|vS)N.zz/.zrrs rrzLazyReferenceMapper._is_metaWs~~d#3u|3rc||jvr|j|=y||jvr|j|=yd|vr|j|sx|jd\}}|j |\}}}|jj ||fi}d||<t ||jk(r|j||yyd|j|<yr) rBr>rrrr3rErgr)rrrHrrkrrs r __delitem__zLazyReferenceMapper.__delitem__[s $++  C DNN "s#cz$--"4"yy~ u#2237 1++00%"E!%w<4#3#33JJuf-4$( C rc ddl}ddl}ddl}|j||f}|xs |jd|d|d} |j |j |jd} |j|j d} |j|j d} |j |j |jd} d}d}|jD]e\}}t|tr-|dz }|d| |<t|dkDs2|d| |<|d | |<C|dz }|jj|| |<g|j| | | | d d }|j j#|j j%xsdz |j&kDr|d j)d|d <ddd}d dg}|j*j-|xs |jd|d|j/| d|xst1|j*dddd d |||j3|jj5||fy)Nrrez/refs.z.parqO)dtypeint64rSrrF)copyr-categoryrutf8)rr-rTexist_okrlstorage_optionszstd)rmr compressionindexstatsobject_encoding has_nulls) kerchunk.dfr^rarBrfullrgnanzerosrr+r%rErw _proc_raw DataFramer-countnuniquerastyperrmkdirs to_parquetgetattrclearpop)rrHrkbase_urlrkerchunkr_rb partitionfnr5offsetsrVrawsnrawnpathjrvrwrrs rrzLazyReferenceMapper.writelsDKK0 )DMM*!E7& F(("&&<((4++7(;))9wwt''sw; ( 6GAt$% 7at9q=!%aGAJ#AwE!H "++//5Q 6\\!     77==?bggoo/41 5 GF**:6BvJ")6:UO  (3dmm4AeW=M  +9tww 148+    (rct|jD]-}t|ts|\}}|j ||||/t|jD]H}|dk7s d|vst j |jj||j|<J|j|jd}t j|j|jd<|jjdj|xs |jdg|jd|j j#y)zOutput any modified or deleted keys Parameters ---------- base_url: str Location of the output )r rrfrrreN)r%rBr+r,rr?rr r>rgr@rArrrr~rrz cache_clear)rr rthingrHrkkrs rflushzLazyReferenceMapper.flushs$++& E%' % v %$3  dkk" CAL TQY$(JJt{{q/A$Bq! C >>$:J:JK$(JJsO$:$:$< L!  HHh/$--> ? KK % ""$rc$d}|jD]J}|jdr|dz }|j|}|jj |}||z }L|t |j z }|t |jz }|S)NrrrS)rCrrDr_productrEr>rB)rrrHrInchunkss r__len__zLazyReferenceMapper.__len__s\\^ !E$ "33E: ''//+6   ! T^^$$ T[[!! rc#Kt|j}|j|j|D]}t |t s||j D]}|j|Ed{y7wr)rr>rrBr+r2rCr)rmetasbitrHs rrJzLazyReferenceMapper.__iter__srDNN# T[[! C#s#  \\^ 2E**51 1 1 2 1sAB -B6A>7BcF |j|y#t$rYywxYw)NTF)rr)ritems r __contains__z LazyReferenceMapper.__contains__s*    t $  s   c #K|j|}t|dk(r|dzytjd|D}|D]2}|dzdj |Dcgc] }t |c}z4ycc}ww)z|List key names in given field Produces strings like "field/x.y" appropriate from the chunking of the array rr<Nc32K|]}t|ywr)r)rrXs rrz5LazyReferenceMapper._keys_in_field..s"A58"Arrer)rDrE itertoolsrr~r2)rrHrIindsindrxs rrz"LazyReferenceMapper._keys_in_fields ++E2 { q $,    "A["AB @C#+#)>Q#a&)> ?? ? @)>sABA; -B)NN T)TNN)rrr __doc__propertyr_rbr staticmethodrrCrrrrrDrrFr&rrrrrrrrrrJr#rrLrrr\r\TsY  SU-#^77 :"x'Rt_ , ,' C<$#r]'' 44("8)t%B  2 @rr\ceZdZdZdZ dfd Zd dZd dZd dZdZ dZ e fd Z d!d Z d"d Zd#d Zd Zd#dZdZdZdZd$dZd%dZdZdZdZd%dZd&fd ZdZdZdZdZdZ dZ!xZ"S)'ReferenceFileSystemaView byte ranges of some other file as a file system Initial version: single file system target, which must support async, and must allow start and end args in _cat_file. Later versions may allow multiple arbitrary URLs for the targets. This FileSystem is read-only. It is designed to be used with async targets (for now). This FileSystem only allows whole-file access, no ``open``. We do not get original file details from the target FS. Configuration is by passing a dict of references at init, or a URL to a JSON file containing the same; this dict can also contain concrete data for some set of paths. Reference dict format: {path0: bytes_data, path1: (target_url, offset, size)} https://github.com/fsspec/kerchunk/blob/main/README.md rc @t|d i|||_| |_| |_i|_i|_i|_| |_| |_ t|trtd i|xs|xsid|i}tjj|fi|\}}|j!|r^tj"|dfi|5}t$j'd|t)j*|}ddd|j-| n#-R[[%"@ Abkk )+DHH_ %  "~~,,. ,C=%C$kk88= ! 8#HG1E2GB)+DHHX&  ,  "--/ C=%Cc4(SV"(++"<"OF0D"FB(*DHH_ %1z&1y(( s;,N !AN Nc |j|}tjd| |j|}t |tr|j}t |trGtjd|d|jdrtj|dd}|ddfSt|dk(r%tjd|d||d}||}}nV|\}}} tjd|d |d |d | || z} ||dk\r||z}n| |z}n|}||dk\r||z}n| |z}n| }| |j}|||fS#t$r t |wxYw) Nzcat: z Reference: z , type bytesbase64:rSz, whole file => rz => z , offset z, size )_strip_protocolrAdebugr.rrr+r2rArrbase64 b64decoderEr) rr-startendpartrnstart1end1start0rend0s r _cat_commonzReferenceFileSystem._cat_commons##D) uTF^$ *??4(D dC ;;=D dE " LL;tfL9 :z*''QR1t# # t9> LL;tf,2B>c .t|tr|rtt|tr|st d|Drtt ||j }i}|jD]U\}}|j|} ggg} } } |D]K} |j| \}}}| j|| j|| j|Mg}g}g}g}t}t| | | |D]u\}}}} t|tr||| <|!|j||j||j||j||j| wt| | | |D]S\}}}} | ||vs|j||j||j||j| Ut!t|t|t|d|j"|j$\}}}| j'|||}t| | | |D]\}}}} | |vr t||||D]i\}}}}||k(r#||t|t(r||| <'||||| <0||k(s6||k\s<||ksBt|t(r||| <X|||z ||z xsd|| <kX|j+jD]\\}} t| t(s||j vs&||}!t-||j |}"|!|"_|dk(r|"|dk7sX|"||<^t1|dk(rt|trd|vr t3|S|S#t$r}|dk(r|dk7r||| <Yd}~d}~wwxYw)Nc3$K|]}d|v yw)*NrL)rrs rrz*ReferenceFileSystem.cat..s7OQq7OsraiseomitT)sortr;r<rSr)r+r2NotImplementedErrorr%anyr8r.rr9r`r4rrrPraddr r;r< cat_rangesrdrr __cause__rEr()#rr-rzon_errorr proto_dictr6protor5rrurlsstartsendsrurYrgerrurls2starts2ends2paths2 whole_files new_paths new_startsnew_ends bytes_outr_nsnebrvexnew_exs# rr}zReferenceFileSystem.cats dC Y% % dD !yC7O$7O4O% %%dDOO< &,,.D BLE5%B!#R$&D % %"..q1GAq!KKNMM!$KKN %EGEF%K!$e< % 1aa'CFY OOA&LLONN1%LLOMM!$ %"$e< % 1a=Qk%9LLONN1%LLOMM!$  %/BU W U  .. / +Iz8 iXFI"$e< B 1a8%(J)%T BMBBQwBJ"*%a3%&CF%&qVCFqQ"Wb%a3%&CF%&q2vR0@D%ACF B BoD BLHHJ$$& $DAq!Y'A,@V.q$//!2DE#% w& L'#CF $ s8q=Zc2s$#;  Q)%7*6)!$A %s AM00 N9NNc|jdd}||j|y|dk(r|j||ytd|)NversionrS)r6z Unknown reference spec version: )r*_process_references0_process_references1r)rr.r6verss rrDz'ReferenceFileSystem._process_references^sS~~i. <  % %j 1 QY  % %jEW % X?vFG Grc||_y)z&Make reference dict for Spec Version 0Nrj)rr.s rrz(ReferenceFileSystem._process_references0is $rcfjr jrddli_j |j dit dfd}|j dijD]\}}t|trF|jdr%tj|ddj|<|j|<\jr|d}d|vrQjr=|jdd jd d jdij}n||}t|d k(r|gn ||d |d gj|<|j|<jj!j#|j dgy)Nrr8icZj|jdijSNrL)Templaterenderr8)rjinja2rs r _render_jinjaz?ReferenceFileSystem._process_references1.._render_jinjass&,6??1%,,>t~~> >rryzbase64:rT{{{z}}}rSrgenrL)r7r8rr._process_templatesr*rrr+r2rrWrXreplacerorEr _process_gen)rr.r6rrrrrs` @rrz(ReferenceFileSystem._process_references1ms~$$   {B ?@ 4 ?  ?NN62.446 'DAq!S!<< *)/)9)9!AB%)@DOOA&%&"aD19,,$AIIdC0$WT3/#V6&*nn6 *!,,/FaKaSa1qt_"%&"% '& t00r1JKLrci|_|j|j|j|jD]1\}}d|vrddl|ffd |j|<#||j|<3y)NrrcFj|jdi|Sr)rr)temprrs rrz8ReferenceFileSystem._process_templates..s*>V__>&>#!>#r)r8r6rrr)rtmprrrs @rrz&ReferenceFileSystem._process_templatessn  " " . JJt.. /IIK &DAqqy01%#q!%&q! &rc^ i}|D]}|djDcic]H\}}|t|tr|n/t|j dd|d|j ddJc}} fdt j jD}|D]}ddl}|j|djd i||j} |j|d jd i||j} d |vrd |vr{t|j|d jd i||j} t|j|d jd i||j} | | | g|| <d |vd |vz r td | g|| <|Scc}}w)N dimensionsrYrstopsteprSc3dK|]'}ttj|)ywr)r=rPrQ)rr& dimensions rrz3ReferenceFileSystem._process_gen..s,S)623s-0rrnrlengthz^Both 'offset' and 'length' are required for a reference generator entry if either is provided.rL)rr+r%rr*r&rr&rrrr8rr)rgensr6rrrproductsprrrrnrrrs @rrz ReferenceFileSystem._process_gens %C  -335 Aqa&155!,aivq9IJKI '//1A1A1CDH %8fooc%j188P2PP8fooc%j188P2PPO(c/ =H 6==UUdnnUF!=H 6==UUdnnUF!$VV4CH#o(c/:$K !$uCH' % %> =sA F)cddgi|_|jj}|D]\}}t|tt fr t |}nt |dk(rd}n|\}}}d|vr|jdddnd}|}|r||jvryg|j|<|jjd|vr|jdddndgj|ddd|j|}|r||jvry|j|j|d|d y)Nr,rSrerrrrd) dircacher.rr+rr2rErsplitr3r4_parent) rrr-r[rrrYparpar0s r_dircache_from_itemsz(ReferenceFileSystem._dircache_from_itemss"R __ " " $ TJD$$ -4yTa!%5$,/4K$++c1%a(RCD4t}}4&( d# ((.1TkDKKQ'*r2&$ QGH||D) 4t}}4 MM#  % %tVT&R S# Trc N|j|}tj|Sr)rsrprq)rr-mode block_size cache_optionsrrvs r_openzReferenceFileSystem._opens}}T"zz$rc z|j|}t|jtr |jj ||S|js|j|j|}| t ||r|S|Dcgc]}|d c}S#t $rYnwxYwt d|dcc}w)N'z' is not a known keyr) rUr+r.r\rrrrr_ls_from_cache)rr-rrr6os rrzReferenceFileSystem.lss##D) doo': ; ))$77}}  % % '!!$' ;#D) ) J#&'a& ''  #av-A$BC C(sB B8 B&%B&c J|j|xs|j|Sr)ror@rr-rs rexistszReferenceFileSystem.existsszz$44;;t#44rc|jr|jvSt|jtr|jj dvSt fd|jDS)Nr,c3FK|]}|jdyw)reNr)rrr-s rrz,ReferenceFileSystem.isdir..s IAq||tfAJ/Is!)rr+r.r\rCrrr-s `rrozReferenceFileSystem.isdirsY ==4==( ( )< =4??22266 6III Irc||jvSrrjrs rr@zReferenceFileSystem.isfilest&&rc2K|j||fi|Swr)r)rr-rrs r_lszReferenceFileSystem._lsstwwtV.v..rc P|rt|f|||d|Sr0|jtfd|jD}nt|j}|r?|j s|j |Dcic]}||j|dc}S|Scc}w)N)maxdepthwithdirsrc3FK|]}|js|ywrr)rrr-s rrz+ReferenceFileSystem.find..sHQQ\\$5GqHs!!r)rfindrUrr.rrr) rr-rrrrrrrs ` rrzReferenceFileSystem.finds 7<'(6MS  ''-DH$//HHAt'A ==))+:;GD!"hhtn11$//$2G2JKDGFOAw9s 8 C3C3c,K|j|Swr)rBrs r_infozReferenceFileSystem._info!syyscxK|jj|d|jjywr)r.r rr rs r_rm_filezReferenceFileSystem._rm_file$s/  $  s8:c^K||j|<|jjywr)r.rr )rr-rvs r _pipe_filezReferenceFileSystem._pipe_file*s$ $ s+-cKt|d5}|j|j|<ddd|jj y#1swY$xYww)Nr4)r readr.rr )rrrrqrOs r _put_filezReferenceFileSystem._put_file/sJ %  .!%&VVXDOOE " .  . .s AA#AAAc i}|jjD]0\}}t|tr |j d||<,|||<2tj|dfi|5}|jtjd|djdddy#t $r,dt j|zj ||<YwxYw#1swYyxYw)z+Write modified references into new locationasciirSrnrS)rryN)r.rr+rrUnicodeDecodeErrorrW b64encoder}r rr?r@rA)rrnrr6rrrOs r save_jsonzReferenceFileSystem.save_json5sOO))+ DAq!U#IXXg.CFA [[d 6o 6 F! GGDJJ1c:;BBD E F F *I(6+;+;A+>>FFHCFI F FsB&'6C&2CCC') NNNNNNNNTii@Br)r-)F)Frr)r4NNr+)NFF)#rrr r.r7rr`rcrsrkrsrrxr*r}rDrrrrrrrrror@rrrBrrrrrr!r"s@rr2r2s H  U2n(!TBB&/@ , 2ZxH%M> &!FT, ("5J'/"*   Frr2),rW collectionsrpr&loggingrr functoolsrtypingr fsspec.corer}ujsonr? ImportErrorasynr callbacksrr>rr r utilsr r r getLoggerrA RuntimeErrorrr(r0r8abc ValuesViewr: ItemsViewrNrZMutableMappingr\r2rLrrrs     #)33@@   - .TLT?  B[__// BAKOO--A ^@+//88^@B L F/L FM sC$$ C21C2