Django Celery 终止任务的子进程

Question

这是我之前问题的后续提问：如何取消一个已经在执行的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/是我见过的最接近我想要做的事情的内容，除了我不想在超时的时候终止，而是想在我用任务ID调用revoke()时终止。

看起来我只有（字符串类型的）任务ID，请问有没有办法终止这些子进程？谢谢你的帮助——我在这方面的经验还不够，查阅文档对我来说有点困难！

Answer 1

试着为 on_revoked 设置一个回调函数，这个函数可以终止任务的子进程。