如何在Celery中检查任务状态?

如何检查一项任务是否在celery中运行(特别是我在使用celery-django)?

我已经阅读了文档,并且已经在Google上进行了搜索,但是看不到类似以下的呼叫:

my_example_task.state() == RUNNING

我的用例是我有一个外部(java)服务来进行代码转换。当我发送要进行代码转换的文档时,我想检查运行该服务的任务是否正在运行,如果没有运行,请(重新)启动它。

我相信我使用的是当前的稳定版本2.4。

回答:

每个Task对象都有一个.request属性,其中包含AsyncRequest对象。因此,以下行给出了Task的状态task

task.AsyncResult(task.request.id).state

以上是 如何在Celery中检查任务状态? 的全部内容, 来源链接: utcz.com/qa/414586.html

回到顶部