Chcę utworzyć grupę z listy zwróconej przez zadanie Seler, tak aby dla każdego elementu w zestawie wyników zadania jedno zadanie zostało dodane do grupy.

Oto prosty przykład kodu wyjaśniający przypadek użycia. The??? powinien być wynikiem poprzedniego zadania.

@celery.task
def get_list(amount):
    # In reality, fetch a list of items from a db
    return [i for i in range(amount)]

@celery.task
def process_item(item):
    #do stuff
    pass

process_list = (get_list.s(10) | group(process_item.s(i) for i in ???))

Prawdopodobnie nie zbliżam się do tego poprawnie, ale jestem pewien, że wywoływanie zadań z poziomu zadań nie jest bezpieczne:

@celery.task
def process_list():
    for i in get_list.delay().get():
        process_item.delay(i)

Nie potrzebuję wyniku zadania sekundowego.