【发布时间】:2018-01-28 19:14:22
【问题描述】:
我有一些 Celery 任务,我正在通过使用任务 ID 实例化 AsyncResult 从单独的进程定期检查它们的状态。
由此,我得到了任务状态。通过实现自定义结果后端和扩展 AsyncResult 类,如here 所述,我也可以获取任务名称。但是,我希望能够为每个任务获取自定义显示名称 - 人类可读的名称,以便我可以以用户友好的方式显示状态信息。
假设,它可能被设置为:
@app.task()
def my_task(args):
display_name = "My Task"
...
...
然后我会做......
result = ExtendedAsyncResult(task_id)
result.display_name
但是从我链接到的自定义结果后端来看,似乎没有任何方法可以访问任务的局部变量。
有没有办法实现我正在寻找的东西?
【问题讨论】:
标签: celery celery-task