Периодическая задача Celery не отображается в таблице django
Использование Django 3.2 и celery для настройки периодических задач на AWS ECS.
У меня много периодических задач, которые выполняются нормально, и я создал 2 новые периодические задачи, но эти задачи не обнаруживаются и не отображаются в таблице Periodic Tasks в Django admin
Конфигурация у меня такая
celery.py
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'qcg.settings')
app = Celery('qcg')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
# Celery-beat-configuration
CELERY_BEAT_SCHEDULE = {
'authentication-1': {
'task': 'authentication.periodic_task.clear_refresh_token',
'schedule': crontab(hour=23)
},
'authentication-2': {
'task': 'authentication.periodic_task.assistance_email_after_registration_task',
'schedule': crontab(hour=2)
},
'authentication-3': {
'task': 'authentication.periodic_task.send_reminder_email_before_deletion_task',
'schedule': crontab(hour=23)
},
'authentication-4': {
'task': 'authentication.periodic_task.delete_inactive_accounts_task',
'schedule': crontab(hour=23)
}
}
В таблице периодических задач отображаются следующие две задачи
- аутентификация-1
- аутентификация-2
В то время как две другие задачи не отображаются в таблице задач периода и также не выполняются.
Настройка celery.py такова
CELERY_RESULT_BACKEND = 'django-db'
CELERY_TASK_DEFAULT_QUEUE = 'celery'
CELERY_TASK_ACCOUNT_QUEUE = 'qcg-account-queue'
CELERY_BROKER_URL = 'sqs://'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_TRACK_STARTED = True
CELERY_RESULT_EXTENDED = True
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'
CELERY_BROKER_TRANSPORT_OPTIONS = {
'visibility_timeout': 43200,
'polling_interval': 60
}
Запуск службы beat как
["celery","-A","qcg","beat","-l","info","--pidfile","/tmp/celerybeat.pid"]
и сельдерейная служба как
["celery","-A","qcg","worker","-l","info","--concurrency","4"]