Как использовать асинхронные функций python в Colaboratory Google?

Question

[Александр]

Добрый день. Изучаю асинхронные функции python с помощью сервиса Colaboratory Google. Прошу помощь сообщества так как функция не запускается. Есть простой пример:

import asyncio
import time
async def waiter() -> None:
    await cook('Паста', 8)
    await cook('Салат Цезарь', 3)
    await cook('Отбивные', 16)

async def cook(order, time_to_prepare):
    print(f'Новый заказ: {order}')
    await asyncio.sleep(time_to_prepare)
    print(order, '- готово')

asyncio.run(waiter())

При запуске в https://colab.research.google.com/ выдает ошибку

asyncio.run() cannot be called from a running event loop

При замене "asyncio.run(waiter())" на "await waiter()" тоже возникает ошибка:
'await' outside function

Подскажите пожалуйста как запустить функцию waiter()?

Ссылка на блокнот с скриптом https://colab.research.google.com/...

Answer 1

[Влад Григорьев]

В ошибки же явно указано, без event_loop не взлетим
замените run на a

syncio.get_event_loop().run_until_complete(waiter())

и заработает, а ещё прочитайте материал про данный модуль

Comments

[Александр]

Большое спасибо за ответ.

В ошибки же явно указано, без event_loop не взлетим

В том то и дело что наоборот :) Если переводить текст ошибки дословно, то:

asyncio.run () не может быть вызван из запущенного цикла событий

Т.е. в Colaboratory Google уже запущен цикл событий. По этому предложенная правка дает ошибку:

This event loop is already running (* Этот цикл событий уже запущен *)

Т.е. основная проблема как запустить асинхронность не запуская новый цикл событий.

По этой же причине не помогла с первого набега документация. Хоти и Colaboratory Google очень удобный для изучения python инструмент, про него там нет ни слова :(.

[Влад Григорьев]

Александр, в документации по asyncio все прекрасно расписано вот не надо тут
для запуска нового есть new_event_loop(), для получения текущего get_event_loop
для создания таски есть create_task
для выполнения функции есть run_until_complete
и так далее
почитайте документацию там все подробно написано

[Александр]

Влад Григорьев, в том то и дело, что средствами описанными в документации вопрос решить не удалось.
Ни запуск нового цикла событий(не дает запустить так как уже запущен), ни добавление task в текущий(выдает странный результат, совершенно не тот который должен быть), не помогают.

[Влад Григорьев]

Александр, https://colab.research.google.com/drive/1S8sbkImyJ... тут работает мой вариант, и локально тем более

[Александр]

Влад Григорьев, там работает уже дрогой вариант с использованием модуля nest_asyncio. Сегодня нашел решение таким образом, хотя некоторые не рекомендуют этот модуль.

Локально возможно, не исключаю. Вопрос был именно про реализацию в блокнотах.

[Влад Григорьев]

Александр,

без всяких костылей, запросили активный евент лууп, сказали выполнить таску все рабит

[Влад Григорьев]

Александр, ну так то ваш код, я его не стал сохранять, отредактировал и все.

[Александр]

Влад Григорьев, благодарю. Предложенный вариант работает без костылей действительно. Спасибо.