Повторная попытка сельдерея с ошибками, которые являются частью цепочки

У меня есть сеть сельдерея, которая выполняет некоторые задачи. Каждая из задач может быть неудачной и может быть повторена. Пожалуйста, смотрите ниже для бы...

Получение GroupResult из taskset_id в Celery?

Я начинаю набор задач с сельдереем, используя группу сельдерея, как описано вофициальная документацияЯ также сохраняю идентификатор группы (taskset) в БД, чт...

Лучший способ сопоставить сгенерированный список с задачей в сельдерее

Сельдерей остановить исполнение цепи

У меня есть задача check_orders, которая 'с выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнен...

ошибка импорта в сельдерее

Сельдерей снова и снова выполняет долго выполняемые задачи

У меня есть очередь Python Celery-Redis, обрабатывающая закачки и закачки, которые стоят за один раз.Немногие из загрузок занимают до нескольких часов. Однак...

Как сделать две задачи взаимоисключающими в сельдерее?

Есть ли способ запретить запуск двух разных задач одновременно в Celery? Я думал о том, чтобы определить новую очередь с уровнем параллелизма = 1 и отправить...

Реализация Django Celery - OSError: [Errno 38] Функция не реализована

Тогда по вашему мнению

могу проверить, если задача (task_id) все еще обрабатывается всельдерей? У меня есть следующий сценарий:Запустить задачу в представлении DjangoСохраните Base...

Вы имеете в виду что-то вроде этого :

ery я хочу запускать задачу только тогда, когда все остальные задачи выполнены. Я нашел некоторые ресурсы, как этот:Сельдерей Начало задачи, когда другие ...