Error with Python 3.10: "ValueError: loop argument must agree with lock" #358
Description
I ran into this in my own project, see simonw/datasette#1481 - then I tried using a fork of this project to run the unit tests against Python 3.10 and got the same error: https://github.com/simonw/janus/runs/3842463703?check_suite_focus=true
============================= test session starts ==============================
platform linux -- Python 3.10.0, pytest-6.2.4, py-1.10.0, pluggy-0.13.1
rootdir: /home/runner/work/janus/janus
plugins: cov-2.12.1, asyncio-0.15.1
collected 72 items
tests/test_async.py FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF [ 43%]
tests/test_mixed.py .FFFFFFFFFFFFFFFFF [ 68%]
tests/test_sync.py FFFFFFFFFFFFFFFFFFFFFFF [100%]
=================================== FAILURES ===================================
__________________________ TestQueueBasic.test_empty ___________________________
self = <test_async.TestQueueBasic object at 0x7fb0f561e4d0>
@pytest.mark.asyncio
async def test_empty(self):
> _q = janus.Queue()
tests/test_async.py:65:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
janus/__init__.py:39: in __init__
self._async_not_empty = asyncio.Condition(self._async_mutex)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <[AttributeError("'Condition' object has no attribute 'locked'") raised in repr()] Condition object at 0x7fb0f569a620>
lock = <asyncio.locks.Lock object at 0x7fb0f569ada0 [unlocked]>
def __init__(self, lock=None, *, loop=mixins._marker):
super().__init__(loop=loop)
if lock is None:
lock = Lock()
elif lock._loop is not self._get_loop():
> raise ValueError("loop argument must agree with lock")
E ValueError: loop argument must agree with lock