7Th?!%SSKJr SSKrSSKrSSKrSSKJr SSKJr SSK r \(a$SSKJ r J r JrJr SSKJr SSKJr \ \\ 4rS \S '"S S 5rg!\ a \(dSSK r NIf=f) ) annotationsN) TYPE_CHECKING) atomic_write)AnyDictIteratorLiteral) TypeAlias)CachingFileSystemr Detailc\rSrSrSrSSjrSSjrSSjrSSSjjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSrg) CacheMetadataaDCache metadata. All reading and writing of cache metadata is performed by this class, accessing the cached files and blocks is not. Metadata is stored in a single file per storage directory in JSON format. For backward compatibility, also reads metadata stored in pickle format which is converted to JSON when next saved. cRU(d [S5eXl0/UlSUlg)z Parameters ---------- storage: list[str] Directories containing cached files, must be at least one. Metadata is stored in the last of these directories by convention. z3CacheMetadata expects at least one storage locationFN) ValueError_storage cached_files_force_save_pickle)selfstorages ]/var/www/auris/envauris/lib/python3.13/site-packages/fsspec/implementations/cache_metadata.py__init__CacheMetadata.__init__%s,RS S +-$#(c[US5n[R"U5nSSS5 WR 5H:n[ URS5[5(dM)[US5US'M< U$!,(df  N^=f![aA [US5n[R"U5nSSS5 M!,(df  N=ff=f)z6Low-level function to load metadata from specific filerNrbblocks) openjsonloadrpicklevalues isinstancegetlistset)rfnfloadedcs r_loadCacheMetadata._load8s (b#!1 A!%%/400!!H+.( !  (b$1Q  (sE BA=B= B B BC$C;C C CCcUR(a+[U5n[R"X5 SSS5 g[USS9n[R"X5 SSS5 g!,(df  g=f!,(df  g=f)z4Low-level function to save metadata to specific fileNw)mode)rrr#dumpr!)rmetadata_to_saver)r*s r_saveCacheMetadata._saveEs_  " "b!Q ,0"!bs+q *.,+"!,+sA'A8' A58 Bc## [UR5n[UR5H@up4X2S- :HnU(a U(dM[RR US5XE4v MB g7f)zYield locations (filenames) where metadata is stored, and whether writable or not. Parameters ---------- writable: bool Set to True to only yield writable locations. Returns ------- Yields (str, str, bool) r cacheN)lenr enumerateospathjoin)r writable_onlynirwritables r_scan_locationsCacheMetadata._scan_locationsNsW  #DMM2JAEzHX'',,w0'C C 3sA0A2c[UR5UR5Huup4pVX;aMXaR5nUbqUR(a$USUR R U5:waMYUR(a+[R"5US- UR:aM[RRXGS5n[RRU5(dMXs4s $ g)zIf path is in cache return its details, otherwise return ``False``. If the optional CachingFileSystem is specified then it is used to perform extra checks to reject possible matches, such as if they are too old. uidtimer)F) ziprArcopy check_filesfsukeyexpiryrEr:r;r<exists)rr;cfsr)base_r7details r check_fileCacheMetadata.check_fileds%((<(<(>@Q@Q$R MRq [%%'F??ve} D8I'I::$))+v">"Kd4L1Bww~~b!!z!%S rc/nURSR5R5Hup4[R"5US- U:dM&UR SS5nU(d[ SU35e[ RRURSU5nURU5 URSRU5 M URS(aL[ RRURSS5nURURSU5 URS(+nX'4$)zRemove expired metadata from the cache. Returns names of files corresponding to expired metadata and a boolean flag indicating whether the writable cache is empty. Caller is responsible for deleting the expired files. rEr)z)Cache metadata does not contain 'fn' for r7) rrGitemsrEr& RuntimeErrorr:r;r<rappendpopr4)r expiry_time expired_filesr;rPr) cache_pathwritable_cache_emptys r clear_expiredCacheMetadata.clear_expireds  --b1668>>@LDyy{VF^+k9ZZb)&CD6JWW\\$--"3R8$$R(!!"%))$/A   R dmmB&7AJ JJt((,j 9#'#4#4R#8822rc/nUR5H^un n[RRU5(a"UR UR U55 MMUR 05 M` U=(d 0/Ulg)z>Load all metadata from disk and store in ``self.cached_files``N)rAr:r;rLrXr-r)rrr)rOs rr"CacheMetadata.loadsh ,,.HB1ww~~b!!##DJJrN3##B' / )0RDrcURSUnUSSLa0[US5UR-UR:aSUS'ggg)z{Perform side-effect actions on closing a cached file. The actual closing of the file is the responsibility of the caller. rTrTN)rr8 blocksizesize)rr*r;r,s ron_close_cached_file"CacheMetadata.on_close_cached_filesT   b !$ ' X;d "s1X;'7!++'E'OAhK(P "rcURUS5nU(dgUup4URURS5(a0URSR U5 UR 5 U$[ S5e)zRemove metadata of cached file. If path is in the cache, return the filename of the cached file, otherwise return ``None``. Caller is responsible for deleting the cached file. NrTzrsf" % 33+)S#XFI&N-N- sAA/.A/