【发布时间】:2012-02-20 20:29:14
【问题描述】:
这是我上一个问题的后续问题: Cancel an already executing task with 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 revoke() 时杀死。
似乎我只有(字符串)task_id,有没有办法杀死这样的子进程?感谢您的帮助 - 我在这方面的经验并不如我所愿,浏览文档是一项挑战!
【问题讨论】:
标签: python django subprocess task celery