asyncio не работает с Google Cloud Functions

Question

У меня есть эта функция, которая отлично работает локально на моем компьютере с python 3.8, но выдает ошибку времени выполнения в Google Cloud Functions.

      def telegram_test(request):
    request_json = request.get_json()
    import datetime
    import pandas as pd
    from pyrogram import Client
    
    session_string = "...............38Q8uTHG5gHwyWD8nW6h................."
    # the rest of the authantication
    api_id = 32494131641215
    api_hash = "ioadsfsjnjksfgnfriuthg#qw]/zwq  ]w/\lc ec,"

    # one of bbc channels on telegram you want to access
    channel_name = 'pyrogram'

    # if you only want to get messages older than 7 days in unix style
    seven_days = int((datetime.datetime.now() - datetime.timedelta(days=7)).timestamp())
    # call telegram with parameters such as limit and date
    # save the result to dataframe

    with Client(session_string,api_id,api_hash, takeout=True,workers=2) as app:
        hist_iter = app.iter_history(channel_name,offset_date=seven_days, limit=100)    
        msglist = [msg.__dict__ for msg in hist_iter]
        df = pd.DataFrame(msglist)
        print(df.head(5))
 
    return f'it works!:{request_json}'

Сообщение об ошибке, которое я получаю из журнала GCF:

Файл "/opt/python3.8/lib/python3.8/asyncio/events.py", строка 639, в get_event_loop поднять RuntimeError('В потоке% r нет текущего цикла событий.' RuntimeError: Нет текущего события цикл в потоке ThreadPoolExecutor-0_0.

Обновлять

Я обновил код, ошибка времени выполнения исчезла. но я получаю ошибку тайм-аута. Я выставил тайм-аут 180 секунд, но все равно, когда я тестирую функцию, время ожидания составляет 60 секунд.

Вот обновленный код. Что-то я делаю не так?

      async def foo():
    from datetime import datetime, timedelta
    from pandas import DataFrame
    from pyrogram import Client
    import asyncio

    session_string = "********zNmkubA4ibjsdjhsdfjlhweruifnjkldfioY5DE*********"    
    api_id = 325511548224831351
    api_hash = "jdffjgtrkjhfklmrtgjtrm;sesews;;wex"        
    channel_name = 'cnn'

    with Client(session_string, api_id, api_hash, takeout=True) as app:
        hist_iter = app.iter_history(
            channel_name, limit=10)
        msglist = [msg.__dict__ for msg in hist_iter]
        df = DataFrame(msglist)    
    return df
 
async def bar():
    return await foo() 

def test(request):
    from asyncio import run
    return run(bar())

Answer 1

В конце концов, решение заключалось в том, чтобы перейти с Pyrogram на телемарафон и создать asyncio вручную перед созданием клиента.

      loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)

Answer 2

1. bar() избыточно
2. Вы пытаетесь вернуть фрейм данных. Это действительный HTTP-ответ?
3. with -> async with
4. hist_iter = app.iter_history() -> hist_iter = await app.iter_history()
5. Мб он ждет ввода?