dtjhddlZddlZddlZddlZddlmZmZddlmZddZ GddeeZ dS) N)AsyncFileSystem running_async)ChainedFileSystemcJtjfd}|S)a Wraps a synchronous function to make it awaitable. Parameters ---------- func : callable The synchronous function to wrap. obj : object, optional The instance to bind the function to, if applicable. semaphore : asyncio.Semaphore, optional A semaphore to limit concurrent calls. Returns ------- coroutine An awaitable version of the function. cKrG4d{Vtjg|Ri|d{Vcdddd{VS#1d{VswxYwYtjg|Ri|d{VSN)asyncio to_thread)argskwargsfunc semaphores a/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/fsspec/implementations/asyn_wrapper.pywrapperzasync_wrapper..wrappersQ  F  F F F F F F F F$.tEdEEEfEEEEEEEE F F F F F F F F F F F F F F F F F F F F F F F F F F F F&t=d===f=========s< A A) functoolswraps)robjrrs` ` r async_wrapperr s@&_T>>>>>> NcjeZdZdZdZdZ d fd ZedZdZ e dZ xZ S) AsyncFileSystemWrapperaX A wrapper class to convert a synchronous filesystem into an asynchronous one. This class takes an existing synchronous filesystem implementation and wraps all its methods to provide an asynchronous interface. Parameters ---------- sync_fs : AbstractFileSystem The synchronous filesystem instance to wrap. ) asyncwrapperrFNc |t}tjdd|i||||_nt j|fi||_|jj|_||_|dS)N asynchronous) rsuper__init__sync_fsfsspec filesystemprotocolr_wrap_all_sync_methods) selffsrtarget_protocoltarget_optionsrmax_concurrent_tasksr __class__s rrzAsyncFileSystemWrapper.__init__8s  (??L==l=f=== >DLL!,_OOOODL - " ##%%%%%rc d|jjS)Nasync_)rfsid)r$s rr,zAsyncFileSystemWrapper.fsidMs+ )+++rcdh}t|jD]}|ds||vrtj|j|}t |t rLt|j|}t|r?tj |s+t|||j }t|d||dS)zg Wrap all synchronous methods of the underlying filesystem with asynchronous versions. open_)rrN) dirr startswithinspectgetattr_static isinstancepropertygetattrcallableiscoroutinefunctionrrsetattr)r$excluded_methods method_nameattrmethod async_methods rr#z-AsyncFileSystemWrapper._wrap_all_sync_methodsQs#8t|,, ? ?K%%c** k=M.M.M)$, DDD$)) T\;77F ?(CF(K(K ?,VXXX /+//>>> ? ?rcHGfdd|}djd|_|S)a Create a new class that can be used to instantiate an AsyncFileSystemWrapper with lazy instantiation of the underlying synchronous filesystem. Parameters ---------- sync_fs_class : type The class of the synchronous filesystem to wrap. Returns ------- type A new class that wraps the provided synchronous filesystem class. c"eZdZfdZxZS)JAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrappercZ|i|}t|dSr )rr)r$r r rr) sync_fs_classs rrzSAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrapper.__init__us5'-888  )))))r)__name__ __module__ __qualname__r __classcell__)r)rCs@rGeneratedAsyncFileSystemWrapperrAts> * * * * * * * * * *rrHAsyncWrapper)rD)clsrCrHs ` r wrap_classz!AsyncFileSystemWrapper.wrap_classcsZ" * * * * * * *c * * * 4M* 3 3 3 (0/.r)NNNNNN) rDrErF__doc__r"cachablerr5r,r# classmethodrLrG)r)s@rrr(s  /HH !&&&&&&*,,X,???$//[/////rr)NN) r rr2r fsspec.asynrrchainedrrrrrrrRs 66666666&&&&&&:T/T/T/T/T/_.?T/T/T/T/T/r