Pobieranie GroupResult z taskset_id w Celery?
Rozpoczynam zestaw zadań selera, używając grupy selera, jak opisano woficjalna dokumentacja
Przechowuję również identyfikator grupy (zestawu zadań) w db, aby sondować seler dla stanu zestawu zadań.
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
Czy istnieje sposób na uzyskanie obiektu GroupResult (tj. Mojegoresult
) zaczynając od identyfikatora zadania? Coś w styluto pytanie, ale pracując z grupami selera.
Próbowałem już:
r = GroupResult(taskset_id)
ale to nie działa, jakr.results()
jest zawsze pusty.
Powinienem użyćGroupResult.save()
iGroupResult.restore()
metody?