taskiq-aio-pika

taskiq-aio-pika copied to clipboard

Inside `AioPikaBroker` class, I had to implement the following logic: ```python class AioPikaBroker(AsyncBroker): ... async def declare_queues( self, channel: AbstractChannel, ) -> AbstractQueue: await channel.declare_queue( self._dead_letter_queue_name, **self._declare_queues_kwargs, ) args: dict[str,...

WiZeYAR

Add support for quorum queues and max_attempts_at_message

3

This addresses the issue https://github.com/taskiq-python/taskiq-aio-pika/issues/35.

Arseniy-Popov

Crash Loop Due To Posion Message Without Quorum Queues

1

If you get a task that crashes the consumer, for example, due to a memory leak, the consumer will enter a crash loop that it is unable to recover from....

Arseniy-Popov

I'm not sure if this issue is part of taskiq-aio-pika, aio-pika, or a combination. Due to temporary network issue, we recently got an `aiormq.exceptions.ChannelInvalidStateError` from our TaskIQ worker. The full...

dave-hellopatient

Tasks not delivered with DIRECT exchange

1

When using ExchangeType.DIRECT, tasks are sent but workers don't consume them due to a routing key mismatch. ## Reproduction: 1. Install dependencies. ```bash pip install taskiq taskiq-aiopika taskiq-redis ``` 2....

recursionhater0