Merge pull request #5822 from escattone/fix-celery-priority-queue-1573

fix issues with Celery task routes
This commit is contained in:
Tasos Katsoulas 2023-12-20 10:52:02 +02:00 коммит произвёл GitHub
Родитель e7301f33f5 8f6f3f6995
Коммит b77eb6c540
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
2 изменённых файлов: 2 добавлений и 3 удалений

Просмотреть файл

@ -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}

Просмотреть файл

@ -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"},
}