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

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

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

Как заставить задачу сельдерея провалиться изнутри задачи?

В некоторых условиях я хочу, чтобы задача сельдерея провалилась из-за этой задачи. Я попробовал следующее: from celery.task import task from celery import states @task() def run_simulation(): if ...

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

У меня есть задача check_orders, которая выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнение задач, и выполнить что-то, когда все они выполнены (это цель res.join [1] и grouped_subs). ...

Вот

устил приложение фляги с работником сельдерея и перерисовал в трех отдельных контейнерах докера без каких-либо проблем. Вот как я начинаю это: celery worker -A app.controller.engine.celery -l info --concurrency=2 --pool eventlet Сельдерей ...

или (в случае, если RabbitMQ управляется Supervisor):

могу удалить все отложенные задачи, не знаяtask_id для каждой задачи?