lints

Author: martindurant

fsspec/implementations/tests/test_asyn_wrapper.py

@@ -20,7 +20,7 @@ class LockedFileSystem(AsyncFileSystem):
     def __init__(
         self,
         asynchronous: bool = False,
-        delays: tuple[float, ...] | None = None,
+        delays=None,
     ) -> None:
         self.lock = asyncio.Lock()
         self.delays = cycle((0.03, 0.01) if delays is None else delays)
@@ -200,7 +200,7 @@ def test_open(tmpdir):
 @pytest.mark.asyncio
 async def test_semaphore_synchronous():
     fs = AsyncFileSystemWrapper(
-            LockedFileSystem(), asynchronous=False, semaphore=asyncio.Semaphore(1)
+        LockedFileSystem(), asynchronous=False, semaphore=asyncio.Semaphore(1)
     )
 
     paths = [f"path_{i}" for i in range(1, 3)]
@@ -211,7 +211,9 @@ async def test_semaphore_synchronous():
 
 @pytest.mark.asyncio
 async def test_deadlock_when_asynchronous():
-    fs = AsyncFileSystemWrapper(LockedFileSystem(), asynchronous=False, semaphore=asyncio.Semaphore(3))
+    fs = AsyncFileSystemWrapper(
+        LockedFileSystem(), asynchronous=False, semaphore=asyncio.Semaphore(3)
+    )
     paths = [f"path_{i}" for i in range(1, 3)]
 
     with pytest.raises(RuntimeError, match="Concurrent requests!"):