Блог

У меня есть задачи с сельдереем

Часть 1

 import time
@periodic_task(run_every=timedelta(minutes=60), softtimelimit=timedelta(minutes=60).total_seconds())
def main():
    time.sleep(30)
 

Часть 2

 import time
@celery.task
def main():
    time.sleep(30)
 

Как обычно при выполнении задач сельдерея в части 2. Я вошел в свое ядро python и запустил

 main.delay()
 

Однако для части 1 тот же фрагмент кода main.delay() привел к исключению.

ValueError: Array member at index 0, 3600.0, is of an unsupported type

В любом случае я могу запускать эту периодическую задачу по требованию, так как мне нужно ее отладить.

Я использую сельдерей 4.4.1