Как ловить исключения в асинхронных функциях?

Question

[Вячеслав Грачунов]

К примеру, кусок кода (событие нового сообщения в telethon):

@client.on(events.NewMessage(chats=('chat')))
			async def normal_handler(event):
				print(event.message.id)
				posts = await client(functions.messages.GetHistoryRequest(
				peer=event.message.to_id,
				limit=1,
				offset_date=None,
				offset_id=0,
				max_id=0,
				min_id=0,
				add_offset=0,
				hash=0))
				print(posts)

Если где-то ниже async допустить ошибку или вообще синтаксически некорректное выражение - программа не падает с исключением, а тупо молча висит. Как такое исправить? Как ловить ошибки?

Comments

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

Можно так

def exception_handler(event_loop, context):  # noqa
    if event_loop.is_closed():
        return
    if "exception" in context.keys():
        tasks = asyncio.all_tasks()
        for task in tasks:
            # noinspection PyProtectedMember
            name = task._coro.cr_code.co_name  # noqa
            if not task.done():
                if name.startswith("test_"):
                    task.cancel()
        raise context["exception"]


event_loop.set_exception_handler(exception_handler)

[Roman K]

Как минимум, стоит прочитать официальную документацию. Как, в общем-то, и всегда.