Как динамически задать время celery??

Question

[mr_drinkens89]

Можно ли как-то указать время запуска задачи динамически? Суть. Есть несколько задач,у которых выставлено время запуска ( разные рассылки). в селери я поставил задачу,которая каждую секунду обращается к таск,и смотрит,что запустить. Можно ли как-то динамически прописать время запуска? Спасибо.

Answer 1

[Yuri Shikanov]

apply_async есть для этого, вот из документации пример:

>>> from datetime import datetime, timedelta

>>> tomorrow = datetime.utcnow() + timedelta(days=1)
>>> add.apply_async((2, 2), eta=tomorrow)