Есть функция, определенная как async:
async def doStuff()
Необходимо таких функций вызвать много и параллельно. Пробую так:
with futures.ProcessPoolExecutor as pool:
running = [await pool.submit(doStuff,arg1),await pool.submit(doStuff,arg2)]
while running:
done,running = futures.wait(running,timeout=30,return_when=ALL_COMPLETED)
for future in done:
session = future.result()
print(session)
Однако, получаю ошибку
with futures.ProcessPoolExecutor as pool:
AttributeError: __enter__
Нельзя использовать async-функции в экзекьюторе?