lint

Author: martindurant

fsspec/implementations/asyn_wrapper.py

@@ -20,10 +20,11 @@ def async_wrapper(func, obj=None):
     coroutine
         An awaitable version of the function.
     """
+
     @functools.wraps(func)
     async def wrapper(*args, **kwargs):
-        self = obj or args[0]
         return await asyncio.to_thread(func, *args, **kwargs)
+
     return wrapper
 
 
@@ -39,6 +40,7 @@ class AsyncFileSystemWrapper(AsyncFileSystem):
     sync_fs : AbstractFileSystem
         The synchronous filesystem instance to wrap.
     """
+
     def __init__(self, sync_fs, *args, **kwargs):
         super().__init__(*args, **kwargs)
         self.asynchronous = True
@@ -82,10 +84,13 @@ def wrap_class(cls, sync_fs_class):
         type
             A new class that wraps the provided synchronous filesystem class.
         """
+
         class GeneratedAsyncFileSystemWrapper(cls):
             def __init__(self, *args, **kwargs):
                 sync_fs = sync_fs_class(*args, **kwargs)
                 super().__init__(sync_fs)
 
-        GeneratedAsyncFileSystemWrapper.__name__ = f"Async{sync_fs_class.__name__}Wrapper"
-        return GeneratedAsyncFileSystemWrapper
+        GeneratedAsyncFileSystemWrapper.__name__ = (
+            f"Async{sync_fs_class.__name__}Wrapper"
+        )
+        return GeneratedAsyncFileSystemWrapper

fsspec/implementations/tests/test_asyn_wrapper.py

@@ -11,27 +11,31 @@
 def test_is_async():
     fs = fsspec.filesystem("file")
     async_fs = AsyncFileSystemWrapper(fs)
-    assert async_fs.async_impl == True
+    assert async_fs.async_impl
 
 
 def test_class_wrapper():
     fs_cls = LocalFileSystem
     async_fs_cls = AsyncFileSystemWrapper.wrap_class(fs_cls)
     assert async_fs_cls.__name__ == "AsyncLocalFileSystemWrapper"
     async_fs = async_fs_cls()
-    assert async_fs.async_impl == True
+    assert async_fs.async_impl
 
 
 @pytest.mark.asyncio
 async def test_cats():
     with filetexts(csv_files, mode="b"):
         fs = fsspec.filesystem("file")
         async_fs = AsyncFileSystemWrapper(fs)
-        
+
         result = await async_fs._cat(".test.fakedata.1.csv")
         assert result == b"a,b\n1,2\n"
 
-        out = set((await async_fs._cat([".test.fakedata.1.csv", ".test.fakedata.2.csv"])).values())
+        out = set(
+            (
+                await async_fs._cat([".test.fakedata.1.csv", ".test.fakedata.2.csv"])
+            ).values()
+        )
         assert out == {b"a,b\n1,2\n", b"a,b\n3,4\n"}
 
         result = await async_fs._cat(".test.fakedata.1.csv", None, None)
@@ -51,12 +55,15 @@ async def test_cats():
         assert result == b"a,b\n1,2\n"[1:-2]
 
         out = set(
-            (await async_fs._cat(
-                [".test.fakedata.1.csv", ".test.fakedata.2.csv"], start=1, end=-1
-            )).values()
+            (
+                await async_fs._cat(
+                    [".test.fakedata.1.csv", ".test.fakedata.2.csv"], start=1, end=-1
+                )
+            ).values()
         )
         assert out == {b"a,b\n1,2\n"[1:-1], b"a,b\n3,4\n"[1:-1]}
 
+
 @pytest.mark.asyncio
 async def test_basic_crud_operations():
     with filetexts(csv_files, mode="b"):
@@ -76,6 +83,7 @@ async def test_basic_crud_operations():
         await async_fs._rm(".test.fakedata.1.csv")
         assert not await async_fs._exists(".test.fakedata.1.csv")
 
+
 @pytest.mark.asyncio
 async def test_error_handling():
     fs = fsspec.filesystem("file")
@@ -87,6 +95,7 @@ async def test_error_handling():
     with pytest.raises(FileNotFoundError):
         await async_fs._rm(".test.non_existent.csv")
 
+
 @pytest.mark.asyncio
 async def test_concurrent_operations():
     with filetexts(csv_files, mode="b"):
@@ -99,11 +108,12 @@ async def read_file(file_path):
         results = await asyncio.gather(
             read_file(".test.fakedata.1.csv"),
             read_file(".test.fakedata.2.csv"),
-            read_file(".test.fakedata.1.csv")
+            read_file(".test.fakedata.1.csv"),
         )
 
         assert results == [b"a,b\n1,2\n", b"a,b\n3,4\n", b"a,b\n1,2\n"]
 
+
 @pytest.mark.asyncio
 async def test_directory_operations():
     with filetexts(csv_files, mode="b"):
@@ -120,6 +130,7 @@ async def test_directory_operations():
         assert ".test.fakedata.2.csv" in filenames
         assert "new_directory" in filenames
 
+
 @pytest.mark.asyncio
 async def test_batch_operations():
     with filetexts(csv_files, mode="b"):
@@ -128,4 +139,4 @@ async def test_batch_operations():
 
         await async_fs._rm([".test.fakedata.1.csv", ".test.fakedata.2.csv"])
         assert not await async_fs._exists(".test.fakedata.1.csv")
-        assert not await async_fs._exists(".test.fakedata.2.csv")
+        assert not await async_fs._exists(".test.fakedata.2.csv")