celery-task

0зной

1ответ

Пропустить журналы Результаты сельдерея

У меня есть небольшой webapp, написанный на Python с использованием Flask. Некоторые конечные точки, которые у меня есть, требуют длительного времени выполнения (~ 60 с +). Решение состоит в том, чтоб

python logging celery celery-task 2017-02-06

---

1зной

1ответ

Использование результата группы в цепочке сельдерея

Я застрял в относительно сложной конфигурации цепи сельдерея, пытаясь добиться следующего. Предположим, что есть цепочка задач, таких как следующие: chain1 = chain( DownloadFile.s("http://someserv

python celery celery-task 2017-02-13

---

1зной

1ответ

Вызов задачи chunk с аргументами ключевого слова

Как я выполняю задачи с аргументами ключевого слова? Например, эта задача: @app.task def add(x, y, multiply=1, unit="GB"): return '%s %s' % ((x + y) * multiply, unit) Я могу назвать эту задачу

python celery celery-task keyword-argument celery-canvas 2017-02-14

---

0зной

1ответ

Настройка атрибутов сельдерея Задачи (i.e time_limit и soft_time_limit) не работают

В соответствии с этим вопросом проблема решена, но похоже, что это не так. Setting Time Limit on specific task with celery Текущая версия сельдерея 3.1.18 (Cipater). Я пытаюсь перезаписать настройки п

celery celery-task 2017-02-19

---

5зной

1ответ

Задачи сельдерея Утеряны после отправки брокеру rabbitmq

У меня возникла странная проблема, когда некоторые из моих задач падают после отправки брокеру. Это происходит примерно в 1 из 10 задач. Я проверил, что нет старого работника сельдерея, потребляющего

rabbitmq celery celery-task 2017-01-18

---