如何在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