Джанго селери припиняють підпроцеси завдання - python, django, підпроцесор, завдання, селера

Це додаткове запитання до мого попереднього запитання: Скасувати вже виконуване завдання за допомогою селери?

celery.task.control.revoke({task_id}, terminate=True)

дійсно вбиває мого працівника, який виконує завдання. У мене зараз виникає проблема, що в моєму завданні запущені підпроцеси, які не вмирають, коли завдання скасовано.

Це повідомлення від dmarkey http://dmarkey.com/wordpress/2011/09/07/killing-child-processes-of-celery-tasks-on-a-timeout/ є найближчим, кого я бачив, що я хочу зробити, за винятком того, що я не хочу вбивати під час таймауту, а швидше, коли я відкликаю () з task_id.

Здається, що все, що у мене є, є (String) task_id,чи все-таки вбивати такі підпроцеси? Дякую за вашу допомогу - я не маю такого багато досвіду з цим, як мені б хотілося, навігація в документах - це складне завдання!

Відповіді:

Спробуйте встановити зворотний дзвінок для on_revoked що вбиває дитину процеси завдання.