From 8827012565fb8522d32d40ae128bfd88278e4253 Mon Sep 17 00:00:00 2001 From: skshetry Date: Mon, 3 Oct 2022 23:18:18 +0545 Subject: [PATCH 1/3] Require latest fsspec for asynclocalfs --- setup.cfg | 1 + 1 file changed, 1 insertion(+) diff --git a/setup.cfg b/setup.cfg index 15b1f04..3e85231 100644 --- a/setup.cfg +++ b/setup.cfg @@ -30,6 +30,7 @@ install_requires= memfs = pygtrie>=2.3.2 asynclocalfs = + fsspec>=2022.10.0 typing_extensions>=3.10.0; python_version < '3.10' aiofile==3.8.1 asynclocal = From 282a724eaa678e892515b39e1c82595239466398 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Saugat=20Pachhai=20=28=E0=A4=B8=E0=A5=8C=E0=A4=97=E0=A4=BE?= =?UTF-8?q?=E0=A4=A4=29?= Date: Mon, 3 Oct 2022 23:28:31 +0545 Subject: [PATCH 2/3] add _{read,write}_{bytes,text} apis --- src/morefs/asyn_local.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/morefs/asyn_local.py b/src/morefs/asyn_local.py index cea34f8..f531643 100644 --- a/src/morefs/asyn_local.py +++ b/src/morefs/asyn_local.py @@ -48,11 +48,15 @@ class AsyncLocalFileSystem(AsyncFileSystem, LocalFileSystem): _mv_file = wrap(LocalFileSystem.mv_file) _pipe_file = wrap(LocalFileSystem.pipe_file) _put_file = wrap(LocalFileSystem.put_file) + _read_bytes = wrap(LocalFileSystem.read_bytes) + _read_text = wrap(LocalFileSystem.read_text) _rm = wrap(LocalFileSystem.rm) _rm_file = wrap(LocalFileSystem.rm_file) _rmdir = wrap(LocalFileSystem.rmdir) _touch = wrap(LocalFileSystem.touch) _symlink = wrap(LocalFileSystem.symlink) + _write_bytes = wrap(LocalFileSystem.write_bytes) + _write_text = wrap(LocalFileSystem.write_text) sign = LocalFileSystem.sign async def _get_file( From 6e340bae3d7aaab7b2a7b4530447a8b095f3aa6a Mon Sep 17 00:00:00 2001 From: skshetry Date: Wed, 19 Oct 2022 21:20:05 +0545 Subject: [PATCH 3/3] Update setup.cfg --- setup.cfg | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/setup.cfg b/setup.cfg index 3e85231..2812db8 100644 --- a/setup.cfg +++ b/setup.cfg @@ -30,7 +30,7 @@ install_requires= memfs = pygtrie>=2.3.2 asynclocalfs = - fsspec>=2022.10.0 + fsspec>=2022.10.0 typing_extensions>=3.10.0; python_version < '3.10' aiofile==3.8.1 asynclocal =