Как добавить настройки celery в django?

Я хотел бы добавить следующую модификацию настроек celery в приложение django

worker_send_task_event = False
task_ignore_result = True
task_acks_late = True 
worker_prefetch_multiplier = 10  

В моем celery.py, я получил

import os

from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'server.settings')

app = Celery('server')

app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

И мой tasks.py

@shared_task
def some_task():
    pass

Селери выполняется с помощью следующего

command: celery -A server worker -Ofair — without-gossip — without-mingle — without-heartbeat

Я добавил их непосредственно в Django settings.py, но я не уверен, что Celery действительно подхватил эти настройки. Поэтому мне интересно, есть ли другой способ добавить их или у кого-то есть подобный опыт?

Я использую

celery==5.2.1
Django==3.2.5

Вам необходимо использовать именование в верхнем регистре, как описано здесь

Пример: Используйте CELERYD_SEND_EVENTS = True вместо worker_send_task_event = False

Вернуться на верх