Результаты поиска по запросу "celery-task"
Вот
устил приложение фляги с работником сельдерея и перерисовал в трех отдельных контейнерах докера без каких-либо проблем. Вот как я начинаю это: celery worker -A app.controller.engine.celery -l info --concurrency=2 --pool eventlet Сельдерей ...
или (в случае, если RabbitMQ управляется Supervisor):
могу удалить все отложенные задачи, не знаяtask_id для каждой задачи?
Сельдерей снова и снова выполняет долго выполняемые задачи
У меня есть очередь Python Celery-Redis, обрабатывающая закачки и закачки, которые стоят за один раз.Немногие из загрузок занимают до нескольких часов. Однак...
Сельдерей остановить исполнение цепи
У меня есть задача check_orders, которая 'с выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнен...
Сельдерей остановить исполнение цепи
У меня есть задача check_orders, которая выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнение задач, и выполнить что-то, когда все они выполнены (это цель res.join [1] и grouped_subs). ...
Лучший способ сопоставить сгенерированный список с задачей в сельдерее
Я ищу несколько советов о том, как лучше сопоставить список, созданный из задачи, с другой задачей в сельдерее. Допустим, у меня есть задача под названиемparse, который анализирует документ PDF и выводит список страниц. Затем каждая страница ...
Вы имеете в виду что-то вроде этого :
ery я хочу запускать задачу только тогда, когда все остальные задачи выполнены. Я нашел некоторые ресурсы, как этот:Сельдерей Начало задачи, когда другие ...
Как заставить задачу сельдерея провалиться изнутри задачи?
В некоторых условиях я хочу, чтобы задача сельдерея провалилась из-за этой задачи. Я попробовал следующее: from celery.task import task from celery import states @task() def run_simulation(): if ...
Страница 1 из 2