We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
declare_queue_kwargs["arguments"]
1 parent 1c834a1 commit b83d989Copy full SHA for b83d989
taskiq_aio_pika/broker.py
@@ -193,6 +193,9 @@ async def declare_queues(
193
}
194
if self._max_priority is not None:
195
args["x-max-priority"] = self._max_priority
196
+ if "arguments" in self._declare_queues_kwargs:
197
+ args.update(self._declare_queues_kwargs["arguments"])
198
+ del self._declare_queues_kwargs["arguments"]
199
queue = await channel.declare_queue(
200
self._queue_name,
201
arguments=args,
0 commit comments