Результаты поиска по запросу "celery-task"
Как заставить задачу сельдерея провалиться изнутри задачи?
В некоторых условиях я хочу, чтобы задача сельдерея провалилась из-за этой задачи. Я попробовал следующее: from celery.task import task from celery import states @task() def run_simulation(): if ...
Повторная попытка сельдерея с ошибками, которые являются частью цепочки
У меня есть сеть сельдерея, которая выполняет некоторые задачи. Каждая из задач может быть неудачной и может быть повторена. Пожалуйста, смотрите ниже для бы...
Сельдерей снова и снова выполняет долго выполняемые задачи
У меня есть очередь Python Celery-Redis, обрабатывающая закачки и закачки, которые стоят за один раз.Немногие из загрузок занимают до нескольких часов. Однак...
Сельдерей остановить исполнение цепи
У меня есть задача check_orders, которая 'с выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнен...
Как сделать две задачи взаимоисключающими в сельдерее?
Есть ли способ запретить запуск двух разных задач одновременно в Celery? Я думал о том, чтобы определить новую очередь с уровнем параллелизма = 1 и отправить...
Получение GroupResult из taskset_id в Celery?
Я начинаю набор задач с сельдереем, используя группу сельдерея, как описано вофициальная документацияЯ также сохраняю идентификатор группы (taskset) в БД, чт...
Я потратил 2 дня, чтобы решить ее, но до сих пор не поблагодарил вас!
я пытался запустить работника, у меня возникла проблема: ImportError: Нет модуля с именем 'project' Traceback (последний вызов был последним): File "/usr/local/bin/celery", line 11, in <module> sys.exit(main()) ...
Лучший способ сопоставить сгенерированный список с задачей в сельдерее
Я ищу несколько советов о том, как лучше сопоставить список, созданный из задачи, с другой задачей в сельдерее. Допустим, у меня есть задача под названиемparse, который анализирует документ PDF и выводит список страниц. Затем каждая страница ...
Страница 1 из 2