The loop argument to asyncio.Queue is deprecated since Python 3.8, and scheduled for removal in Python 3.10

[tirkarthi]

mode/mode/threads.py

Line 331 in 56216a2

self._queue = asyncio.Queue(loop=self.loop)

  /root/py39-venv/lib/python3.9/site-packages/mode/threads.py:331: DeprecationWarning: The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.
    self._queue = asyncio.Queue(loop=self.loop)

[lindycoder]

Trying to use with python 3.10 via Faust, so this is currently blocking, is there any known workaround ?

[taybin]

Use the updated version at https://github.com/faust-streaming/mode/, available on pypi as mode-streaming.