У меня есть большой файл 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
Как я могу дождаться завершения всех задач сельдерея, прежде чем продолжить свой код? ⇐ Python
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Как настроить работника сельдерея для выполнения только задач с высоким приоритетом?
Anonymous » » в форуме Python - 0 Ответы
- 24 Просмотры
-
Последнее сообщение Anonymous
-