from celery.signals import celeryd_after_setup

@celeryd_after_setup.connect
def add_dynamic_queue(sender, instance, **kwargs):
    queue = 'dynamic_queue'
instance.app.amqp.queues.select_add(queue)
Celery worker: как потреблять из всех очередей?