Не удается получить свойство Celery run_every для работы

Question

Я пытаюсь создать некоторые Периодические задачи Сельдерея, и некоторые из них должны иметь возможность изменять время выполнения во время выполнения. Документация Celery говорит, что я должен это сделать, превратив атрибут run_every в свойство (http://packages.python.org/celery/faq.html#can-i-change-the-interval-of-a-periodic-task-at-runtime).

Вот что я делаю:

class ParseSomeStuffTask(PeriodicTask): 

    def run(self, **kwargs): 
     # Do stuff 

    @property 
    def run_every(self): 
     if datetime.now().weekday() in [1, 2, 3]: 
      return timedelta(minutes=15) 
     else: 
      return timedelta(seconds=40) 

К сожалению, когда я перехожу на celerybeat, я получаю следующее сообщение об ошибке:

[Thu Sep 09 15:44:40 2010: CRITICAL/828]: celerybeat raised exception : 'datetime.timedelta' object has no attribute 'is_due'

Он затем выключается. Документация Celery действительно не вписывается в то, что нужно вернуть при создании свойства run_every, и мне не повезло найти Google. Изменения в сельдереях говорят, что он смог изменить интервалы Периодической задачи во время выполнения с версии 1.0.0.

Дев. Окружающая среда:

• Python 2.6.5
• Django 1.2.1
• сельдерея 2.0.2

Answer 1

сельдерея 2.0 поддерживает различные модели поведения в расписании. Там celery.task.schedules.schedule и celery.task.schedules.crontab.

Вы должны вернуть один из них или создать свой собственный подкласс расписания.

from celery.task.schedules import schedule 

@property 
def run_every(self): 
    if datetime.now().weekday() in [1, 2, 3]: 
     return schedule(timedelta(minutes=15)) 
    else: 
     return schedule(timedelta(seconds=40)) 

Атрибут run_every будет автоматически преобразован в конкретизации, , но не позже.