У меня есть большой файл csv, который я разбил на список фрагментов по 100 000 строк каждый, передал каждый фрагмент функции для выполнения сложных вычислений и добавил результат в global_list.
когда последний фрагмент будет Закончив, я беру global_list и делаю некоторую статистику.
Как я могу попросить сельдерей обрабатывать все фрагменты параллельно, но ждать, пока последняя задача/последний фрагмент не будет завершена, прежде чем выполнять функцию complex_calc в global_list?
Спасибо за помощь
for chunk in global_chunk_list:
def func_calc.delay(chunk) #
Подробнее здесь: https://stackoverflow.com/questions/553 ... ng-my-code
