async def wrapped_coroutine() -> Optional[Message]:
    try:
        result = (await coroutine)
        return result
    except asyncio.CancelledError:
        pass
    except Exception as e:
        tb = traceback.format_exc()
        connection.log.error(f'Exception: {e}, {connection.get_peer_info()}. {tb}')
        raise e
    return None
async def wrapped_coroutine() -> Optional[Message]:
    try:
        result = (await coroutine)
        return result
    except asyncio.CancelledError:
        pass
    except Exception as e:
        tb = traceback.format_exc()
        connection.log.error(f'Exception: {e}, {connection.get_peer_info()}. {tb}')
        raise e
    return None