django – 在芹菜中终止任务3.1.18

概述我有一个 django应用程序与一些芹菜任务,我正在盯着工人 celery -A myapp worker --loglevel=INFO --concurrency=10 我用task.deploy()运行任务,但是当我尝试用celery.task.control.revoke终止任务时(task_id,terminate = True) 我越来越 [2015-07-27 14:27:04,73 我有一个 django应用程序与一些芹菜任务,我正在盯着工人

celery -A myapp worker --loglevel=INFO --concurrency=10

我用task.deploy()运行任务,但是当我尝试用celery.task.control.revoke终止任务时(task_ID,terminate = True)

我越来越

[2015-07-27 14:27:04,736: ERROR/MainProcess] Task task[80e06e87-f254-4c0b-bea5-5c21540777ab] raised unexpected: Terminated(15,)Traceback (most recent call last):  file "/home/blake/projects/venv/myapp/lib/python2.7/site-packages/billiard/pool.py",line 1674,in _set_terminated    raise Terminated(-(signum or 0))Terminated: 15

我正在寻找关于这个错误的帖子,但我只发现了3年的帖子,根本没有帮助我.

我正在使用

celery==3.1.18kombu==3.0.25billiard==3.3.0.20

那么如何成功终止已经运行的任务呢？

编辑：但是任务被终止但代码由于异常而停止执行,并且除了没有捕获异常之外

try:    revoke(task_ID,terminate=True)except Terminated:    pass

解决方法 创建任务时,您需要指定将在任务中抛出的异常

from billiard.exceptions import Terminated@task(throws=(Terminated,))def task():   ...

总结

以上是内存溢出为你收集整理的django – 在芹菜中终止任务3.1.18全部内容，希望文章能够帮你解决django – 在芹菜中终止任务3.1.18所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。