Bug: Queue consumer raises timeout
on komachi: dcl -f
rabotnik_1 | During handling of the above exception, another exception occurred:
rabotnik_1 |
rabotnik_1 | Traceback (most recent call last):
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aio_pika/queue.py", line 27, in consumer
rabotnik_1 | return await create_task(callback, message, loop=loop)
rabotnik_1 | File "/srv/rabotnik/rabotnik/bus.py", line 136, in wrap
rabotnik_1 | await callback(dict(json.loads(message.body.decode())))
rabotnik_1 | File "/srv/rabotnik-instance/rules/get_floorspace.py", line 43, in evaluate
rabotnik_1 | async for data in self.storage.iter_results(query_data):
rabotnik_1 | File "/srv/rabotnik/rabotnik/storages/postgresql.py", line 75, in iter_results
rabotnik_1 | with (await self.pool.cursor()) as cur:
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aiopg/pool.py", line 414, in cursor
rabotnik_1 | conn = await self.acquire()
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aiopg/pool.py", line 317, in _acquire
rabotnik_1 | await self._cond.wait()
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/async_timeout/__init__.py", line 55, in __aexit__
rabotnik_1 | self._do_exit(exc_type)
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/async_timeout/__init__.py", line 92, in _do_exit
rabotnik_1 | raise asyncio.TimeoutError
rabotnik_1 | asyncio.exceptions.TimeoutError
rabotnik_1 | Task exception was never retrieved
rabotnik_1 | future: <Task finished name='Task-82142739' coro=<consumer() done, defined at /usr/local/lib/python3.9/dist-packages/aio_pika/queue.py:25> exception=TimeoutError()>
rabotnik_1 | Traceback (most recent call last):
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aiopg/pool.py", line 307, in _acquire
rabotnik_1 | async with async_timeout.timeout(self._timeout), self._cond:
rabotnik_1 | File "/usr/lib/python3.9/asyncio/locks.py", line 14, in __aenter__
rabotnik_1 | await self.acquire()
rabotnik_1 | File "/usr/lib/python3.9/asyncio/locks.py", line 120, in acquire
rabotnik_1 | await fut
rabotnik_1 | asyncio.exceptions.CancelledError
rabotnik_1 |
rabotnik_1 | During handling of the above exception, another exception occurred:
rabotnik_1 |
rabotnik_1 | Traceback (most recent call last):
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aio_pika/queue.py", line 27, in consumer
rabotnik_1 | return await create_task(callback, message, loop=loop)
rabotnik_1 | File "/srv/rabotnik/rabotnik/bus.py", line 136, in wrap
rabotnik_1 | await callback(dict(json.loads(message.body.decode())))
rabotnik_1 | File "/srv/rabotnik-instance/rules/get_floorspace.py", line 43, in evaluate
rabotnik_1 | async for data in self.storage.iter_results(query_data):
rabotnik_1 | File "/srv/rabotnik/rabotnik/storages/postgresql.py", line 75, in iter_results
rabotnik_1 | with (await self.pool.cursor()) as cur:
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aiopg/pool.py", line 414, in cursor
rabotnik_1 | conn = await self.acquire()
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/aiopg/pool.py", line 317, in _acquire
rabotnik_1 | await self._cond.wait()
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/async_timeout/__init__.py", line 55, in __aexit__
rabotnik_1 | self._do_exit(exc_type)
rabotnik_1 | File "/usr/local/lib/python3.9/dist-packages/async_timeout/__init__.py", line 92, in _do_exit
rabotnik_1 | raise asyncio.TimeoutError
rabotnik_1 | asyncio.exceptions.TimeoutError
rabotnik_1 | Task exception was never retrieved
rabotnik_1 | future: <Task finished name='Task-82142740' coro=<consumer() done, defined at /usr/local/lib/python3.9/dist-packages/aio_pika/queue.py:25> exception=TimeoutError()>
rabotnik_1 | Traceback (most recent call last):\cc @fd