Dlaczego Celery nie wyłącza się w sposób czysty?

Question

Po dwukrotnym wysłaniu sygnału TERM do pracownika Seler (zatrzymanie na ciepło i zimne wyłączenie) za pomocą przerwań klawiatury Ctlr-C, pracownik Seler jest po prostu zawieszony. Nie pochłania wiadomości ani nie wykonuje zadań (zgodnie z oczekiwaniami), ale też nie wyłącza się.

Przeprowadziłem strace w procesach selera, aby zobaczyć, co dzieje się za sceną. Oto wynik strace na PID procesu głównego Seler

strace -p 27867 
Process 27867 attached - interrupt to quit 
futex(0xb966a78, FUTEX_WAIT, 0, NULL 

i oto co znalazłem robi strace na procesy dziecko:

strace -p 27874 
Process 27874 attached - interrupt to quit 
select(4, [3], NULL, NULL, {0, 562000}) = 0 (Timeout) 
futex(0x871a808, FUTEX_WAKE, 1)   = 0 
select(4, [3], NULL, NULL, {1, 0})  = 0 (Timeout) 
futex(0x871a808, FUTEX_WAKE, 1)   = 0 
...................................................... 

Wiem, że mógłbym wystawić sygnał KILL do procesów do pozbądź się ich. Ale ciekawi mnie, co tak naprawdę uniemożliwia zamknięcie tych procesów i czy można coś z tym zrobić.

Software stosu: Python 2.6.2, 2.4.6 selera, CentOS 5.0

UPDATE: Użycie procesora jest w dół do prawie 0%. Te zadania wymagają dość dużego obciążenia procesora, więc oznacza to, że żadne zadania nie są aktualnie aktywne.

Answer 1

Z docs:

Jeżeli pracownik nie wyłączanie po taktowny czasie, na przykład ponieważ zadań wbitych w nieskończonej pętli, można użyć sygnału KILL zmusić wypowiedzieć pracownikowi , ale należy pamiętać, że obecnie wykonywanie zadań zostanie utracone (chyba że zadania mają ustawioną opcję acks_late ).

Również z google groups:

celeryd nie zostanie wyłączony, dopóki wszystkie aktywne zadania zostały przetworzone, gdzie aktywny oznacza zadania, które zostały rozpoczęte na (nie wszystkie zarezerwowanych zadań). Zarezerwowane komunikaty zostaną zwolnione, a ponownie dostarczone, gdy kanał połączenia zostanie zamknięty. Zdarza się to po powrocie aktywnych zadań. jeśli nie masz - sewerd z włączonym limitem czasu nigdy nie zabije twoich zadań podczas zamykania, nawet jeśli ukończenie DNI potrwa DAYS.