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

@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()

问题：芹菜有什么东西可以检测团体任务的进度吗？我可以计算出那里有多少任务以及已处理了多少任务？

解决方法:

在shell上修补(ipython的选项卡自动完成)我发现group_task(这是一个celery.result.ResultSet对象)有一个名为completed_count的方法,它给出了我所需要的.

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

标签：python,django,celery,django-celery
来源： https://codeday.me/bug/20190901/1781382.html