celery-task

0зной

1ответ

Динамически добавлять функции в существующие рабочие процессы сельдерея?

Я начинаю с сельдерея, и я хочу знать, можно ли добавлять модули к процессам celeryd, которые уже были запущены. Другими словами, вместо добавления модулей через celeryconfig.py как в CELERY_IMPORTS =

python distributed-computing celery celery-task 2011-01-12

---

2зной

1ответ

Проблемы с распределением переменных между сельдерием

Я использую Python и celery в проекте. В проекте, у меня есть два файла: celeryconfig.py BROKER_URL = "amqp://guest:[email protected]:5672//" CELERY_RESULT_BACKEND = "amqp" CELERY_IMPORTS = ("exampl

python multiprocessing celery celery-task celeryd 2011-12-28

---

11зной

2ответ

Проверка, если задача сельдерея все еще обрабатывается

Как проверить, обрабатывается ли задача (task_id) в celery? У меня есть следующий сценарий: Запустить задачу в представлении Django МАГАЗИНУ BaseAsyncResult в сессии Shutdown сельдерей демон (жесткий)

python django celery celery-task 2010-12-02

---

6зной

1ответ

python celery max-tasks-for-child-setting default

Я использую сельдерей, и я хочу использовать max-tasks-per-child-setting , потому что некоторые из процессов сельдерея получают высокую память. Я пытаюсь найти значение по умолчанию для этого параметр

python celery celery-task 2012-04-18

---

1зной

1ответ

сельдерея государственная задача не обновляет

Я вижу странную проблему с приложением Django, который использует сельдерей в качестве очереди задач: Я пнуть задачу. Во время выполнения задача вызывает update_state (...), чтобы установить состояние

heroku celery django-celery celery-task 2012-01-10

---

8зной

2ответ

Сброс обратного отсчета по заданию Сельдерея

Мне нужно, чтобы задача сельдерея выполнялась после обратного отсчета, но при необходимости можно сбросить этот обратный отсчет. Например, я хочу позвонить apply_async с countdown=15, но если определе

django celery celery-task 2012-03-06

---

1зной

1ответ

Django Celery AbortableTask использование

Я использую функцию AbortableTask Celery, но пример документации для меня не работает. Пример, приведенный в: from celery.contrib.abortable import AbortableTask def MyLongRunningTask(AbortableTask):

python django celery celery-task 2010-09-07

---