o Rh @sNddlZddlZddlZddlZddlmZmZdddZGdddeZdS)N)AsyncFileSystem running_asynccstfdd}|S)aF 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. Returns ------- coroutine An awaitable version of the function. cs tjg|Ri|IdHSN)asyncio to_thread)argskwargsfunce/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/fsspec/implementations/asyn_wrapper.pywrapperszasync_wrapper..wrapper) functoolswraps)r objr r r r async_wrapper srcsReZdZdZdZdZ    d fdd ZeddZd d Z e d d Z Z 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 s^|durt}tjdd|i||dur||_n tj|fi||_|jj|_|dS)N asynchronousr )rsuper__init__sync_fsfsspec filesystemprotocol_wrap_all_sync_methods)selffsrtarget_protocoltarget_optionsr __class__r r r1s  zAsyncFileSystemWrapper.__init__cCsd|jjS)Nasync_)rfsid)rr r r r#CszAsyncFileSystemWrapper.fsidcCsdh}t|jD]7}|ds||vrqt|j|}t|tr!qt|j|}t|r?t |s?t ||d}t |d||qdS)zg Wrap all synchronous methods of the underlying filesystem with asynchronous versions. open_)rN) dirr startswithinspectgetattr_static isinstancepropertygetattrcallableriscoroutinefunctionrsetattr)rexcluded_methods method_nameattrmethod async_methodr r r rGs   z-AsyncFileSystemWrapper._wrap_all_sync_methodscs(Gfddd|}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. cseZdZfddZZS)zJAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrappercs|i|}t|dSr)rr)rrrr)r! sync_fs_classr r rkszSAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrapper.__init__)__name__ __module__ __qualname__r __classcell__r r5r r GeneratedAsyncFileSystemWrapperjsr;AsyncWrapper)r6)clsr5r;r r:r wrap_classYs z!AsyncFileSystemWrapper.wrap_class)NNNN) r6r7r8__doc__rcachablerr+r#r classmethodr?r9r r r r r!s  rr) rrr(r fsspec.asynrrrrr r r r s