celery.sh

celeryd -I q2_tasks -l info -Q tasks
celeryd -I q2_tasks -l info -Q count

celeryconfig.py

BROKER_URL = "redis://localhost:6379/0"

# Redis Backend
CELERY_RESULT_BACKEND = "redis"
CELERY_REDIS_HOST = "localhost"
CELERY_REDIS_PORT = 6379
CELERY_REDIS_DB = 0
CELERY_SEND_EVENTS = True

# CELERY_DEFAULT_QUEUE = "default"
CELERY_DEFAULT_EXCHANGE = "default"
CELERY_QUEUES = {
    "default": {
        "exchange": "default"
    },
    "tasks": {
        "exchange": "tasks"
    },
    "count": {
        "exchange": "tasks"
    }
}

run_tasks.py

from tasks import add

add.apply_async((1,1))
add.apply_async((1,1), queue='tasks')
add.apply_async((1,1), queue='count')

tasks.py

from celery.task import task


@task(exchange="tasks")
def add(x, y):
    result = x + y
    return "I am queue 2.", result