мне показалось, там была доля насмешки.

А мы-то люди лёгкие, мы вроде как и не заметили, если даже она там и была. Всё проще. 🙈

а я не вымещал зло и у меня хорошее настроение, окис?
или мне скобочки после каждого предложения ставить?)))))))))))))))))))))))))

ребят )))  есть вопрос у меня по asyncio

Ребя у меня есть вот мной написанный  код:
https://paste.ee/p/cLoi1
В нем я пытаюсь подключится к телеграму через async telethon   и в это же время подключится к своему серверу чтобы получать сообщения от телеграма.
В функции create_my_task я создаю подключение к своему серверу.
Но проблема в том что  например когда я пытаюсь  подключится к серверу которые не доступен я отлавливаю ошибку:

while True:
    try:
        self.reader, self.writer = await asyncio.open_connection('localhost', 9990)
    except OSError as e:
        print("OSError : tcp_client_start")
        await asyncio.sleep(5) 
        continue

но каждый раз когда я пытаюсь подключится по истечении 5 секунд у меня падает ошибка но вместе с ней в htop у меня создается какой то подпроцесс.
И я не могу понять что я делаю не так))  Я первый раз пишу в асинхронном стиле и мне кажетсчя я что то не так сделал  или не допонял.
Цель в том что  если сервер не доступен клеинт пытался к нему подключится раз в 5 секунд и  по хорошему в это время все остальное должно приостоновится  до  получения self.reader, self.writer

что я тут делаю не так))?

Будет ли этот код блокировать поток, когда идет отсылание данных в БД? Если я запускаю функцию через create_task?

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

У меня метод update_one - отсылает в БД и будет блокировать поток получается?

Да

да, если время блокировки маленькое, то не критично

Ок, а если я этот метод через loop.run_in_executor() запущу?

возможно будет дольше выполняться из-за оверхеда, но не заблокирует остальных

Т.е. в main файле я вызываю функцию send_lang  через create_task, в этой функции вызываю update_one через run_in_executor, то main файл спокойно продолжит работу без блокировки потока?

ага, но лучше последовать совету Богдана и использовать асинк клиенты БД

Спасибо большое, а почему лучше асинк клиенты?

потому что они не будут использовать пул потоков/процессов

Выкидывает dic object is not callable, почему???

            info_dict = await loop.run_in_executor(None, ydl.extract_info(url, download=True))

exctract info_возращает dict