* format code

fair_async_rlock/fair_async_rlock.py

@@ -1,7 +1,9 @@
 import asyncio
 from collections import deque
 
-__all__ = ['FairAsyncRLock']
+__all__ = [
+    'FairAsyncRLock'
+]
 
 
 class FairAsyncRLock:
@@ -46,9 +48,9 @@ async def acquire(self):
             self._owner = me
             self._count = 1
         except asyncio.CancelledError:
-            try: # if in queue, then cancelled before release
+            try:  # if in queue, then cancelled before release
                 self._queue.remove(event)
-            except ValueError: # otherwise, release happened, this was next, and we simulate passing on
+            except ValueError:  # otherwise, release happened, this was next, and we simulate passing on
                 self._wait_event = False
                 self._owner = me
                 self._count = 1

fair_async_rlock/tests/test_fair_async_rlock.py

@@ -375,15 +375,14 @@ async def task2():
             t2_ac.set()
             await asyncio.sleep(1.)  # Let's ensure the lock is held for a bit
 
-
     task1 = asyncio.create_task(task1())
     task2 = asyncio.create_task(task2())
     await asyncio.sleep(0.1)  # Yield control to allow tasks to start
     task2.cancel()
     with pytest.raises(asyncio.CancelledError):
         await task2
-    assert not t2_ac.is_set() # shouldn't acquire
-    t1_done.set() # Let T1 finish
+    assert not t2_ac.is_set()  # shouldn't acquire
+    t1_done.set()  # Let T1 finish
     await task1  # Ensure task1 has a chance to release the lock
     # Ensure that lock is not owned and queue is empty after cancellation
     assert lock._owner is None
@@ -610,6 +609,7 @@ async def task4():
     await asyncio.wait([t4], timeout=1)
     assert task4_acquired.is_set()
 
+
 @pytest.mark.asyncio
 async def test_gh17_regression():
     lock = FairAsyncRLock()
@@ -651,4 +651,4 @@ async def task3():
     t2 = asyncio.create_task(task2())
     t3 = asyncio.create_task(task3())
 
-    await asyncio.gather(t1, t2, t3)
+    await asyncio.gather(t1, t2, t3)