Как заставить сельдерей повторить попытку, используя того же воркера?

Я только начинаю работать с сельдереем в проекте Django, и я как бы застрял на этой конкретной проблеме: по сути, мне нужно распределить длительную задачу между разными исполнителями. На самом деле задача разбита на несколько этапов, выполнение каждого из которых требует значительного времени. Поэтому, если какой-либо шаг завершится неудачно, я бы хотел, чтобы сельдерей повторил эту задачу, используя того же рабочего, чтобы повторно использовать результаты выполненных шагов. Я понимаю, что сельдерей использует маршрутизацию для распределения задач на определенный сервер, но я не могу найти ничего об этой конкретной проблеме. Я использую RabbitMQ в качестве своего брокера.

6
задан BartoszKP 22 June 2014 в 23:10
поделиться