从Celery中的tasket_id中检索GroupResult?
发布于 2021-01-29 16:05:59
我还将组(任务集)ID存储到db中,以便为任务集状态轮询celery。
job = group([
single_test.s(1, 1),
single_test.s(1, 2),
single_test.s(1, 3),
])
result = job.apply_async()
test_set = MyTestSet()
test_set.taskset_id = result.id
# store test_set into DB
有没有一种方法可以result
从任务集ID开始获取GroupResult对象(即my
)?类似于在此问题中所做的事情,但与芹菜团体合作。
我已经尝试过:
r = GroupResult(taskset_id)
但是它不起作用,因为r.results()
它总是空的。
我应该使用GroupResult.save()
和GroupResult.restore()
方法吗?
关注者
0
被浏览
50
1 个回答