diff --git a/bin/run-celery-worker.sh b/bin/run-celery-worker.sh index b06d52149..4d6cf4ab8 100755 --- a/bin/run-celery-worker.sh +++ b/bin/run-celery-worker.sh @@ -1,3 +1,3 @@ #!/bin/bash -exec newrelic-admin run-program celery -A kitsune worker --max-tasks-per-child=${CELERY_WORKER_MAX_TASKS_PER_CHILD:-25} +exec newrelic-admin run-program celery -A kitsune worker -Q celery,priority --max-tasks-per-child=${CELERY_WORKER_MAX_TASKS_PER_CHILD:-25} diff --git a/kitsune/celery.py b/kitsune/celery.py index cea3d1d98..7d27bd434 100644 --- a/kitsune/celery.py +++ b/kitsune/celery.py @@ -9,8 +9,7 @@ app = Celery("kitsune") app.config_from_object("django.conf:settings", namespace="CELERY") app.autodiscover_tasks() app.conf.task_routes = { - "kitusne.announcements.tasks.send_group_email": {"queue": "priority"}, + "kitsune.announcements.tasks.send_group_email": {"queue": "priority"}, "kitsune.messages.tasks.email_private_message": {"queue": "priority"}, "kitsune.tidings.tasks.send_emails": {"queue": "priority"}, - "kitsune.messages.tasks.email_private_messages": {"queue": "priority"}, }