Почему возникает ошибка asyncio на ubuntu?

Question

[MaxBat]

Написал телеграм бота на aiogram. На windows все работает хорошо, однако при запуске на сервере вылазит несколько таких одинаковых ошибок.

Exception in callback _SelectorSocketTransport._read_ready()
handle:
Traceback (most recent call last):
File "/usr/lib/python3.10/asyncio/events.py", line 80, in _run
self._context.run(self._callback, *self._args)
RuntimeError: cannot enter context: <_contextvars.Context object
at 0x7f4f04a71000> is already entered

Comments

[fenrir]

Justa Gain, я полностью согласен, что в 99% случаев это не требуется, но вообще впендюривать ничего не требуется для этого в 3.9 добавили asyncio.to_thread чтобы упростить делегирование пулу потоков.

[MaxBat]

Justa Gain, да, все верно

[MaxBat]

Justa Gain, у меня стояла задача запустить синхронную функцию, которая работает постоянно и асинхронный телеграм бот на aiogram одновременно. Однако проблемы возникают из-за того, что я использую bot.send_message в этой синхронной функции одного потока, когда пулинг в другом

[MaxBat]

Justa Gain, в синхронной функции бесконечный цикл, из-за которого телеграм бот не отвечает. Если запустить синхронную функцию через run_in_executor

[MaxBat]

Justa Gain, возможно не так поняли. У меня телеграм бот. Мне нужно чтобы пулинг и функция, в которой куча долгого асинхронного кода и в которой используется await bot.send_message работали одновременно. Чтобы эта куча асинхронного кода не стопила пулинг, а пулинг не стопил асинхронный код. Сама по себе функция асинхронная из-за await bot.send_message. Одновременность исполнения это все что мне нужно. Основной акцент именно на этот синхронный функционал в проекте. Несколько часов не могу решить эту проблему.

[MaxBat]

Justa Gain, предполагаю что да, но не понимаю к чему это

[MaxBat]

Justa Gain, функция асинхронная из-за await bot.sendmessage, просто много долгого синхронного кода

[MaxBat]

Justa Gain, Хорошо, у меня есть две синхронные функции, которые мне нужно запустить паралельно. Каждую из них я засунул в await loop.run_in_executor и обернул в async функцию. Получил две асинхронные функции. В if __name__="__main" написал

loop=asyncio.get_event_loop()
loop.create_task(первая полученная асинхронная функция в которой await run_in_executor, в котором первая синхронная функция из 2, которые нужно запустить паралельно)
loop.create_task(вторая)

Что дальше