Это вопрос, следующий за моим предыдущим вопросом: Отменить уже выполняющуюся задачу с помощью Celery?
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/ это самое близкое, что я видел, к тому, что я хочу сделать, за исключением того, что я не хочу убивать по таймауту, а когда я revoke () с task_id.
Похоже, что все, что у меня есть, это (String) task_id, есть ли способ убить такие подпроцессы? Спасибо за вашу помощь - у меня не так много опыта, как хотелось бы, навигация по документам - это проблема!