У меня есть код, который циклически просматривает некоторые файлы, а затем выполняет последующие вызовы «цепочки» из нескольких API, используя содержимое каждого файла, причем каждому API для запуска необходимы выходные данные предыдущего.
/>
Код: Выделить всё
files = [file_1.png, file_2.png, file_3.png]
for file in files:
out_1 = call_api_1(file)
out_2 = call_api_2(file, out_1)
...
out_n = call_api_n(file, out_nminus1)
save_final_output(out_n)
Как я могу запустить этот код параллельно, не только распараллеливая цикл считываемых файлов, но и так, чтобы каждый последующий вызов API выполнялся параллельно и только тогда, когда выходные данные из предыдущий готов для каждого отдельного файла?
Например, я хотел бы начать вызывать api_1 для каждого файла параллельно, и пока он выполняется, начать вызывать api_2 только для содержимого, обработанного api_1, и так далее .
Подробнее здесь:
https://stackoverflow.com/questions/793 ... -in-python