python Celery -从组标识符中检索子项

cyvaqqii  于 2023-05-16  发布在  Python
关注(0)|答案(1)|浏览(141)

是否可以仅使用组标识符检索任务列表?

from celery import group

def f1():
    task_group = group(task1, task2)
    return task_group().id

def f2(group_id):
    pass
    # TODO: return task1.id and task2.id

GroupResult(id=f1()).children返回None

uttx8gqw

uttx8gqw1#

这似乎起作用:

from celery import group

def f1():
    task_group = group(task1, task2)
    task_group.save()
    return task_group().id

def f2(group_id):
    task_group = GroupResult.restore(id=group_id)
    return task_group.children

相关问题