from celery.signals import celeryd_after_setup

@celeryd_after_setup.connect
def add_dynamic_queue(sender, instance, **kwargs):
    queue = 'dynamic_queue'
Celery worker: How to consume from all queues?