Как мне отложить задачу с помощью сельдерея?

Question

Не говорю о методе delay.

Я хочу иметь возможность получить задачу, учитывая ее task_id и изменить ее ETA на лету, прежде чем она будет выполнена.

На данный момент я должен отменить его и изменить его. Неприятно, если в запланированный процесс вовлечено много вещей.

Answer 1

Если вы используете django-celery и PeriodicTask с DatabaseScheduler, вам нужно изменить интервал PeriodicTask или crontab и сохранить его. Если ваша задача определяется интервалом, измените свойство last_run_at.

Вы запускаете celerybeat с планировщиком базы данных с:

python manage.py celerybeat -S djcelery.schedulers.DatabaseScheduler

Answer 2

Вы должны хранить некоторое значение 'pause' вне очереди сельдерея / задачи. Я делаю это с помощью почтовой программы с использованием сельдерея. Я могу приостановить части системы, установив значения либо в memcache или mysql. Задачи затем проверяют внешний ресурс перед выполнением задачи. Если он должен быть приостановлен, он устанавливает task.retry (), который заставляет его проходить через время задержки повтора и тому подобное.