Not compatible with Python 3.10 (loop parameter for async.Queue has been removed) about stan.py HOT 5 OPEN

This is due to the fact that the transfer of the event loop to the Queue class from the async io package has been removed since python 3.10.
This is evidenced by the documentation:
https://docs.python.org/3/library/asyncio-queue.html#asyncio.Queue

Just try to remove the passing of the 'loop' parameter in the asyncio-nats-client library classes that are used in this asyncio-nats-streaming (stan.py) library.

from stan.py.

@redoc23, @wallyqs
Unfortunately, this doesn't fix the error.

1. After removing parameter loop=self._loop from self._flush_queue = asyncio.Queue the new error occurs:

....\venv\lib\site-packages\nats\aio\client.py:319: in connect
await self._select_next_server()

async def _select_next_server(self):
await asyncio.sleep(
self.options["reconnect_time_wait"], loop=self._loop
)
TypeError: sleep() got an unexpected keyword argument 'loop'

2. After removing parameter loop=self._loop from asyncio.sleep the following error occurs:

....\venv\lib\site-packages\nats\aio\client.py:319: in connect
await self._select_next_server()

while True:
if len(self._server_pool) == 0:
self._current_server = None
raise ErrNoServers
nats.aio.errors.ErrNoServers: nats: No servers available for connection

But the server is available.

from stan.py.

Unfortunately, simply removing references to the loop is not possible. The self._loop is what is used to create the task to ping the server, which would probably break the functionality if it were removed.

Is there any plan to update this library to work with Python 3.10?

210                self._ping_server_task = self._loop.create_task(
211                    self._ping_server())

from stan.py.

Hello to everyone. I understand this issue of compatibility is still present. I would be happy to contribute with a PR that helps bridging this gap, since I myself use stan in my system.

Anyone knows if the owners of the repo are still around, in order to hopefully review such a PR?

from stan.py.

@AdolfoVillalobos I can try to take a look if you send the PR

from stan.py.