Co dzieje się z zaplanowanymi (eta) pracownikami selera po jego wyłączeniu?

Question

Uczyłem się o selerze i nie mogłem znaleźć odpowiedzi na pytanie pojęciowe i eksperymenty były dziwne.

Kiedy są zaplanowane zadania (według harmonogramu, nie mam na myśli okresowych, ale zaplanowanych do uruchomienia w przyszłości przy użyciu eta = x) przekazanych do firmy Celery, wydają się być od razu pobierane z kolejki przez pracownika (raczej niż pozostawanie w domyślnym kluczu/kolejce selera Redis). Przypuszczalnie pracownik faktycznie wykona zadania w eta.

Co się stanie, jeśli pracownik zostanie zamknięty lub uruchomiony ponownie (na przykład w celu zaktualizowania zarejestrowanych zadań)? Czy te zaplanowane zadania zostaną utracone? Nie "biegną", więc ciepłe zakończenie nie czekałoby na ich zakończenie.

Czy istnieje sposób zmuszenia tych zadań do powrotu do kolejki i skonsumowania przez następnego dostępnego pracownika?

Przypuszczam, ręcznie, można zrzucić zadania przed zamknięciem pracownika:

http://celery.readthedocs.org/en/latest/userguide/workers.html#inspecting-workers

i ponownie je, gdy nowy pracownik jest z powrotem ... ale to ma się dziać automatycznie?

naprawdę wdzięczni za każdą pomoc z tym

Dzięki

Answer 1

Spójrz na acks_late http://celery.readthedocs.org/en/latest/reference/celery.app.task.html#celery.app.task.Task.acks_late

Jeśli ma wartość true Seler zachowa zadanie w kolejce, aż została pomyślnie wykonana.