Получение GroupResult из taskset_id в Celery?
Я начинаю набор задач с сельдереем, используя группу сельдерея, как описано вофициальная документация
Я также сохраняю идентификатор группы (taskset) в БД, чтобы опросить сельдерея для состояния набора задач.
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
Есть ли способ получить объект GroupResult (т.е. мойresult
) начиная с идентификатора набора задач? Что-то вроде того, что сделано вэтот вопрос, но работает с сельдереем.
Я уже пытался сделать:
r = GroupResult(taskset_id)
но это не работает, так какr.results()
всегда пусто
Должен ли я использоватьGroupResult.save()
а такжеGroupResult.restore()
методы?