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/ 是我见过的最接近我想要的东西做,除了我不想在超时时杀死,而是当我用task_id撤销()时.

似乎我所拥有的只是(String)task_id,无论如何都要杀死这些子进程？感谢您的帮助 - 我没有像我想的那样有这么多的经验,浏览文档是一个挑战!

Answer 1

尝试设置一个回调来on_revoked杀死任务的子进程。