是否可以仅使用组标识符检索任务列表?
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
GroupResult(id=f1()).children
None
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
1条答案
按热度按时间uttx8gqw1#
这似乎起作用: