Сделать, что бы две функции работали?

Question

[ArtikSK]

def flud(accou....):
    member_n = 0
    while True:
        app = Client(name=....)
        text = choice(messages)

        async def in_flud():
            async with app:
                await app.send_message(chat_id=chat.id, text=text)
                await app.stop()
        app.run(in_flud())
        sleep(delay)

Comments

[ArtikSK]

Dr. Bacon, как функцию flud переделать в async def, что бы использовать, если там внутри находиться app.run?

Answer 1

[Vindicar]

asyncio создаёт цикл-реактор (loop) только для главного потока. Если тебе нужен отдельный реактор в другом потоке (что само по себе повод остановиться и задуматься - нахрена?), создавай его сам в начале потока, потом уже вызывай асинхронный код.
См. asyncio.new_event_loop() и asyncio.set_event_loop().

Comments

[ArtikSK]

мне делать из как отдельную таску?

async def flud(accou....):
    member_n = 0
    while True:
        app = Client(name=....)
        text = choice(messages)

        async def in_flud():
            async with app:
                await app.send_message(chat_id=chat.id, text=text)
                await app.stop()
        asyncio.create_task(await app_flud.run(await in_flud()))
        await asyncio.sleep(delay)

но так выводиться ошибка:

raise RuntimeError('This event loop is already running')
RuntimeError: This event loop is already running
sys:1: RuntimeWarning: coroutine 'idle' was never awaited