Сельдерей цепей групп кормления групп
Мой вопрос похож на Как связать задачу Celery, которая возвращает список в группу?, который в основном спрашивает, как мы делаем:
process_list = (get_list.s(10) | group(process_item.s(i) for i in ???))
и ответом было подделать группу с заданием. Теперь возникает проблема, если вы хотите расширить цепочку за пределы последней группы:
process_list = (get_list.s(10) | dmap.s((process_item.s(i) for i in ???) | do_something.s())
затем dmap возвращается GroupResults который не может быть обработан do_something, Есть идеи?
PS: dmap решение будет работать только с pickle кодировщик а не с новым стандартом json кодировщик.