>>> import asyncio
>>> import aio_pika
>>> loop = asyncio.get_event_loop()
>>> loop.run_until_complete(aio_pika.connect("amqp://debug:debug@127.0.0.1:5672/debug"))
Traceback (most recent call last):
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 521, in connect
await self.close(e)
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/base.py", line 131, in __closer
await self._cancel_tasks(exc)
asyncio.exceptions.CancelledError
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/abc.py", line 44, in __inner
return await self.task
asyncio.exceptions.CancelledError
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "", line 1, in
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/asyncio/base_events.py", line 649, in run_until_complete
return future.result()
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/connection.py", line 388, in connect
await connection.connect(timeout=timeout)
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/connection.py", line 118, in connect
self.transport = await UnderlayConnection.connect(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/abc.py", line 666, in connect
connection = await cls.make_connection(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/abc.py", line 654, in make_connection
connection: aiormq.abc.AbstractConnection = await asyncio.wait_for(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/asyncio/tasks.py", line 408, in wait_for
return await fut
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 918, in connect
await connection.connect(client_properties or {})
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/base.py", line 164, in wrap
return await self.create_task(func(self, *args, **kwargs))
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/abc.py", line 46, in __inner
raise self._exception from e
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/asyncio/tasks.py", line 650, in _wrap_awaitable
return (yield from awaitable.await())
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/abc.py", line 46, in __inner
raise self._exception from e
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 511, in connect
frame = await self._rpc(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 429, in _rpc
raise AMQPInternalError(
pamqp.exceptions.AMQPInternalError: ("one of ['Connection.OpenOk']", <Connection.Close object at 0x1017d1800>)
Minimal steps to reproduce:
During handling of the above exception, another exception occurred:
Traceback (most recent call last): File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/abc.py", line 44, in __inner return await self.task asyncio.exceptions.CancelledError
The above exception was the direct cause of the following exception:
Traceback (most recent call last): File "", line 1, in
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/asyncio/base_events.py", line 649, in run_until_complete
return future.result()
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/connection.py", line 388, in connect
await connection.connect(timeout=timeout)
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/connection.py", line 118, in connect
self.transport = await UnderlayConnection.connect(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/abc.py", line 666, in connect
connection = await cls.make_connection(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aio_pika/abc.py", line 654, in make_connection
connection: aiormq.abc.AbstractConnection = await asyncio.wait_for(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/asyncio/tasks.py", line 408, in wait_for
return await fut
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 918, in connect
await connection.connect(client_properties or {})
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/base.py", line 164, in wrap
return await self.create_task(func(self, *args, **kwargs))
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/abc.py", line 46, in __inner
raise self._exception from e
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/asyncio/tasks.py", line 650, in _wrap_awaitable
return (yield from awaitable.await())
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/abc.py", line 46, in __inner
raise self._exception from e
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 511, in connect
frame = await self._rpc(
File "/Users/peach/.pyenv/versions/3.10.9/lib/python3.10/site-packages/aiormq/connection.py", line 429, in _rpc
raise AMQPInternalError(
pamqp.exceptions.AMQPInternalError: ("one of ['Connection.OpenOk']", <Connection.Close object at 0x1017d1800>)