celery dinamic queue bootstrap

worker.py

from celery import Celery
from kombu import Queue, Exchange

PREFIX = 'baz'
EXCHANGE = 'exchange'

def get_task_names():
    return (
        '%s.foo.bar' % PREFIX, 
        'celery',
    )


def get_queues():
    queues = []
    exchange = Exchange(name=EXCHANGE, type='direct')
    for name in get_task_names():
        queue = Queue(name=name,
                      exchange=exchange,
                      routing_key=name,)
        queues.append(queue)
    return queues

celery_app = Celery()
celery_app.conf.update(task_queues=get_queues())
celery_app.autodiscover_tasks(get_task_names())