python - 跟踪 celery.group 任务的进度？

Question

@celery.task
def my_task(my_object):
    do_something_to_my_object(my_object)


#in the code somewhere 
tasks = celery.group([my_task.s(obj) for obj in MyModel.objects.all()])
group_task = tasks.apply_async()

问题:celery有没有检测组任务进度的东西？我可以计算那里有多少任务以及处理了多少任务吗？

Answer 1

修改 shell(ipython 的选项卡自动完成)我发现 group_task(这是一个 celery.result.ResultSet 对象)有一个名为 completed_count 这正是我所需要的。

还在 http://docs.celeryproject.org/en/latest/reference/celery.result.html#celery.result.ResultSet.completed_count 找到了文档