Сельдерей/Kombu игнорируя run_every

Question

Я установка kombu/celery, которую я недавно установил. Задачи выполняются отлично, но они работают почти непрерывно, а не уважают атрибут run_every. Возможно, более странно, это поведение появляется только в производстве и прекрасно работает на местном уровне.

Мои tasks.py выглядит следующим образом:

from celery.task import PeriodicTask 
from datetime import timedelta, datetime 

class FirstTask(PeriodicTask): 
    run_every = timedelta(seconds = 30) 
    # Do Stuff  

Мои settings.py включает

BROKER_URL = "django://" 

import djcelery 
djcelery.setup_loader() 

плюс 'djcelery' и 'kombu.transport.django' в INSTALLED_APPS.

И в производстве я запускаю python manage.py celeryd -v 2 -B -s celery -E -l INFO, чтобы начать выполнение моих задач. Я следил за Chase Seibert's tutorial, если это очищает что-то еще.

Answer 1

Как долго требуется выполнить задачу? И попробовали ли вы очистить свою очередь, прежде чем повторять попытку (сельдерей может не уважать настройку run_every, если у вас уже есть задачи в вашей очереди ...)

Answer 2

Почему вы добавляете 'kombu.transport.django' в свой INSTALLED_APPS ..? Я думал, что сельдерей и комбу обеспечивают такую ​​же функциональность.