Robotail/Corp
Robotail/Corp
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: исправлен паттерн роутинга Celery задач уведомлений

Browse Source 
Изменено: notifications.tasks.* → notifications.*

Проблема: задачи регистрируются как 'notifications.send_*',
а не 'notifications.tasks.send_*', поэтому старый паттерн
не совпадал и задачи шли в дефолтную очередь 'celery'.

Теперь задачи корректно роутятся в очередь 'notifications',
которую worker слушает с флагом -Q celery,notifications
This commit is contained in:
lizerk 2026-03-11 09:58:53 +03:00
parent 2bf1079280
commit b6ad3c3469
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
backend/eusrr_backend/settings.py
View File

@ -512,11 +512,11 @@ CELERY_TASK_TIME_LIMIT = 30 * 60 # 30 минут максимум на зада
CELERY_TASK_SOFT_TIME_LIMIT = 25 * 60 # Мягкий лимит - 25 минут
# Приоритеты очередей
# CELERY_TASK_ROUTES = {
# 'notifications.tasks.*': {'queue': 'notifications'},
# 'documents.tasks.*': {'queue': 'default'},
# 'employees.tasks.*': {'queue': 'default'},
# }
CELERY_TASK_ROUTES = {
'notifications.*': {'queue': 'notifications'},
'documents.tasks.*': {'queue': 'default'},
'employees.tasks.*': {'queue': 'default'},
}
# Настройки для периодических задач (Celery Beat)
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'