Python: Как вызвать асинхронную функцию из синхронной при действующем event loop?

Question

[centum]

Есть стэк вызова функций:

[main async func0] -> [sync func1] -> [sync func2] -> [async func3]

Как вызвать async func3 из func2 если func1 ничего не знает о асинхронности?
func2 передается в func1, как реализация интерфейса.

Если делать так:

from asgiref.sync import async_to_sync

def func2():
  result = async_to_sync(func3)()

то получаем ошибку:

RuntimeError: You cannot use AsyncToSync in the same thread as an async event loop - just await the async function directly.

Но я не могу вызвать напрямую через await, т.к. func1 ничего не знает об асинхронности.

Comments

[Дмитрий]

Так не нужно делать примерно никогда.

Answer 1

[Vindicar]

Заверни асинхронный коллбэк в синхронную обёртку (можно лямбду), которая вызывает asyncio.create_task() для целевой корутины, и передавай эту обёртку как коллбэк.
Если же ты контролируешь func2, то ещё проще, вставь вызов create_task() туда.
Вот если нужно дождаться результата выполнения, то будет сложнее - но можно засунуть обработку результата в асинхронную часть.

Comments

[centum]

func2 контролируется полностью.
я догадывался, что можно через `asyncio.create_task(func3())` это сделать. Но как получить результат для вызывающей функции func1 ?

[Vindicar]

А вот тут уже никак по-нормальному не сделаешь.
Есть совет на stackoverflow, но это то ещё извращение.

[centum]

Посмотрел на stackoverflow - они там запускают в отдельном потоке с новым event loop корутину. Я же думал, что можно использовать ткущий event loop. Но теперь уже понимаю, что так сделать нельзя, т.к. синхронный код отдаст управление только после своего завершения. Другими словами синхронный код в func2 заблокирует сам себя.
Спасибо за объяснение.