L i/.UddlmZddlZddlZddlZgdZiZded<ejeZ dZ ddZ idd d d d d dd dddd dddd dddidd d d dddidddd dddidd d!d d"dd#id$d%d&d d'dd(id)d*d+d d,d-d.d ddd/id0dd1iid2dd3id4d5d6d d7d8d9d d:dd;idd d?d@dAd dBdCdDd dEd5d6d dFddd dGdHdId dJdKdLd dMdKdLd dNdOdPd dQdOdPd dRdSdTd dUdVdWd dXdd/iidYddZid[d\d]d d^d\d_d d`dadbd dcddded dfddgidhdidjd dkdldmd dndldmd dodpdqd drddsidtdudvd dwdpdqd dxddyidzd{d|d d}d{d|d d~ddd ddd ddd ddidZ e e ee k(sJddZdZddZdZdZy)) annotationsN)registryget_filesystem_classdefaultzdict[str, type] _registryfilect|trA|tvr"|dur|t|dk7r%td|d||xs|d|dt|<yy|tvr|durt ||urtd|dy|t |<y) aAdd implementation class to the registry Parameters ---------- name: str Protocol name to associate with the class cls: class or str if a class: fsspec-compliant implementation class (normally inherits from ``fsspec.AbstractFileSystem``, gets added straight to the registry. If a str, the full path to an implementation class like package.module.class, which gets added to known_implementations, so the import is deferred until the filesystem is actually used. clobber: bool (optional) Whether to overwrite a protocol with the same name; if False, will raise instead. errtxt: str (optional) If given, then a failure to import the given class will result in this text being given. FclasszName (z;) already in the known_implementations and clobber is Falsez import failed for protocol r errz.) already in the registry and clobber is FalseN) isinstancestrknown_implementations ValueErrorrr)nameclsclobbererrtxts U/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/fsspec/registry.pyregister_implementationrs(#s ( (W-=+D1':: TF#  KC5(DTF!K+ !$ ' ; 8 5 0c) TF"PQ* "IdOabfszadlfs.AzureBlobFileSystemzBInstall adlfs to access Azure Datalake Gen2 and Azure Blob Storager adlzadlfs.AzureDatalakeFileSystemz+Install adlfs to access Azure Datalake Gen1 arrow_hdfsz-fsspec.implementations.arrow.HadoopFileSystemz2pyarrow and local java libraries required for HDFS asynclocalz&morefs.asyn_local.AsyncLocalFileSystemz:Install 'morefs[asynclocalfs]' to use AsyncLocalFileSystem asyncwrapperr z:fsspec.implementations.asyn_wrapper.AsyncFileSystemWrapperaz blockcachez/fsspec.implementations.cached.CachingFileSystemboxzboxfs.BoxFileSystemz,Please install boxfs to access BoxFileSystemcacheddaskz0fsspec.implementations.dask.DaskWorkerFileSystemz5Install dask distributed to access worker file systemdataz*fsspec.implementations.data.DataFileSystemdbfsz0fsspec.implementations.dbfs.DatabricksFileSystemz? ?#H- 5 #HmCL.I J 8 CsJ%);; J  5cggen-1 4 5sA** B3BBzYour installed version of s3fs is very old and known to cause severe performance issues, see also https://github.com/dask/dask/issues/10276 To fix, you should specify a lower version bound on s3fs, or update the current installation. cd|vr|jdd\}}n|jdd\}}|dk(}tj|}|r9|jj dddgkrt j t|j dD]}t||}t|tst|d|S)aKTake a fully-qualified path and return the imported class or identifier. ``fqp`` is of the form "package.module.klass" or "package.module:subobject.klass". Warnings -------- This can import arbitrary modules. Make sure you haven't installed any modules that may execute malicious code at import time. :.s3fs05z is not a class) rsplit importlib import_module __version__splitwarningswarns3_msgrSr type TypeError)fqpmodris_s3parts rrPrPs czJJsA& TJJsA& T 6ME  ! !# &C &&s+sCj8 f 3!c4 ! c4 3%/00 Jrc f|dk(rtjdtt|}|di|S)zInstantiate filesystems for given protocol and arguments ``storage_options`` are specific to the protocol being chosen, and are passed directly to the class. rzfThe 'arrow_hdfs' protocol has been deprecated and will be removed in the future. Specify it as 'hdfs'.)rbrcDeprecationWarningr)rNstorage_optionsrs r filesystemro4s: <  ;  x (C  ! !!rc ttS)zReturn a list of the implemented protocols. Note that any given protocol may require extra packages to be importable. )listrrlrravailable_protocolsrrEs % &&r)FN)rgr) __future__rr^typesrb__all__r__annotations__MappingProxyTyperrrrrqsortedrrdrProrrrlrrrysB"  9 ? "5 ! !) , ("Zl ,S l  0<  l@Cl9Kl"M#l( ,S )l07MN1l2 &= 3l: wIJ;l< CF =lD WB CElF CM GlN GA BOlP8 (Ql^ (4 _lf WD Eglh'STilj G? @kll &> mlt 6Dul|;<}l~ =@ lF ;9 GlN ABOlV &> Wl^ @C _lf /? gln =Q olv =Qwl~ C= lFC=GlN /FOlVI4Wl^ gE F_l` wHIalb &; clj&6klr &F slzC>{lB'QRClD 1 0 ElT '0K LUlV (1L MWlX =C Yl`GRSalb ;P clj =C klr G? @slt &W ul| &W}lD (1R SElH31 :C ? @Wl\ !"f-B&CCC < :""'r