Wykrywanie, kiedy zadanie związane z selerem i wszystkie podzadania zostało ukończone.

Question

Mam zadanie nadrzędne, które spowoduje odrodzenie arbitralnej i potencjalnie dużej liczby podzadań. Kiedy zarówno rodzic, jak i wszystkie podzadania zostały zakończone, muszę ustawić flagę w mojej bazie danych, aby wskazać, że jest gotowa. Jak najlepiej to zrobię?

Na przykład:

@task() 
def master_task(foo): 
    foo_obj = Foo.objects.get(id=foo) 
    for bar in foo_obj.bar_set.all(): 
     more_work.delay(bar.id) 

@task() 
def more_work(bar): 
    bar_obj = Bar.objects.get(id=bar) 
    do_work() 

muszę wykryć kiedy master_task i wszystkich podzadań to ma tarła zakończeniu tak, że mogę ustawić flagę na pokrewnego modelu wskazują, że wszystko jest gotowe

Answer 1

Zastosowanie chords

należy użyć [taskset] [1]: > THE taskset umożliwia łatwe wywołanie kilku zadań na raz, a następnie jest w stanie przyłączyć się do wyników w w takiej samej kolejności, w jakiej były wykonywane zadania.

Answer 2

celery.chord jest przeznaczony właśnie do tego.