ishtar_common/utils_celery.py


1
2
3
4
5
6
7
8
9

from kombu import Exchange, Queue


def config_celery_queue(celery_conf):
    task_queues = (
        Queue('low_priority', Exchange('low_priority'), routing_key='low_priority'),
        Queue('celery', Exchange('celery'), routing_key='celery'),
    )
    celery_conf.task_queues = task_queues