celery-task

5Ciepło

1Odpowiedz

Odzyskaj wynik z 'task_id' w Celery z nieznanego zadania

Jak mogę pobrać wynik zadania, jeśli nie wiem wcześniej, które zadanie zostało wykonane? Oto konfiguracja: Biorąc pod uwagę następujące źródła ('tasks.py'): from celery import Celery app = Celery('t

python celery jobs celery-task 2014-06-24

---

10Ciepło

3Odpowiedz

Jak wprowadzać argumenty zadań selerowych do bazy danych, które mają być sprawdzane; używając mysql

Używam MySql jako backend wyniku dla selera. Chcę również przechowywać argumenty programu w DB. Na przykład: add.apply_async(args=[num1, num2, user] W tym przypadku chcę, aby przechowywać argumentu

python mysql celery celery-task 2016-07-13

---

6Ciepło

1Odpowiedz

AsyncResult (id_zadania) zwraca stan "OCZEKUJĄCY", nawet po uruchomieniu zadania.

W projekcie próbuję odpytać task.state długo działającego zadania i zaktualizować jego stan pracy. Działało to w fazie rozwoju, ale nie zadziała, gdy przeniesię projekt na serwer produkcyjny. Ciągle o

python django celery django-celery celery-task 2014-07-01

---

12Ciepło

1Odpowiedz

Pracownik nie zajmuje się zadaniami po selerze numer jeden nazywa się

Chciałbym wykorzystać Celery'ego (z RabbitMQ jako backend MQ) do wykonywania zadań o różnych smakach za pośrednictwem różnych Kolejek. Jednym z wymogów jest to, że konsumpcja (przez pracowników) z okr

python rabbitmq queue celery celery-task 2017-08-20

---

5Ciepło

1Odpowiedz

W selerze, jak uzyskać status zadania dla wszystkich zadań dla określonej nazwy zadania?

W celery chcę uzyskać status zadania dla wszystkich zadań dla określonej nazwy zadania. Dla tego wypróbowanego poniżej kodu. import celery.events.state # Celery status instance. stat = celery.event

python celery celery-task celeryd 2013-07-22

---

5Ciepło

1Odpowiedz

Czy zatwierdzane są zadania wstępne w selera naciowego?

Mam następujących konfiguracji: RabbitMQ maklera + Django Seler z CELERYD_PREFETCH_MULTIPLIER = 32 (mam dużo małych zadania zatem preselekcji im sprawia, że ​​wiele sensu z realizacji punktu widzenia)

django rabbitmq celery celery-task 2017-02-13

---

5Ciepło

1Odpowiedz

Seler Process 'Pracownik' wyszedł z 'kodem błędu 1'

seler pracownika (część kolby APP) jest zabity przed rozpoczęciem: parametry konfiguracyjne Seler (Windows, Seler 1.3.25, RabbitMQ (najnowsza)) flask_app = Flask(__name__) flask_app.secret_key = 'som

python celery celery-task 2017-12-12

---

7Ciepło

3Odpowiedz

Jak usunąć zadanie z selera z brokerem redis?

muszę dodać trochę źle task do celery z REDiS broker ale teraz chcę, aby usunąć niepoprawne task i nie mogę znaleźć żadnych sposób to zrobić Czy istnieje niektóre polecenia lub niektóre API Zrób to ?

python celery celery-task celeryd 2013-06-19

---

14Ciepło

1Odpowiedz

Wyślij zadanie e-mail z właściwym kontekście

Ten kod jest mój skrypt pracownik seler: from app import celery, create_app app = create_app('default') app.app_context().push() Kiedy próbuję uruchomić pracownika będę się do tego błędu: File "/h

python python-2.7 flask celery celery-task 2015-12-04

---

5Ciepło

1Odpowiedz

Łańcuch selera pęka, jeśli jedno z zadań się nie powiedzie

Jaki jest sens łańcucha selera, jeśli cały łańcuch pęknie, jeśli jedno z zadań się nie powiedzie? !! mam ten łańcuch Seler: res = chain(workme.s (y=1111), workme2.s(2222), workme3.s(3333),)() I zrob

python django celery celery-task djcelery 2013-06-25

---