# in settings
CELERY_DEFAULT_QUEUE = 'default'
CELERY_QUEUES = (
    Queue('default'),
    Queue('important', Exchange('red'), routing_key='red'),
)

CELERY_ROUTES = {
    'api.tasks.actualizar_coordenadas_mensajeros_task': {'queue': 'important'},
}

# in api.tasks
@task(queue="important", name="actualizar_coordenadas_mensajeros_task")
def actualizar_coordenadas_mensajeros_task():
	#content

# workers
python manage.py celeryd -Q important
python manage.py celeryd