topoteretes--cognee/cognee/modules/users/methods/get_user.py

from uuid import UUID
from sqlalchemy import select
from sqlalchemy.orm import selectinload
from cognee.infrastructure.databases.relational import get_relational_engine
from cognee.infrastructure.databases.exceptions import EntityNotFoundError
from ..models import User


async def get_user(user_id: UUID):
    db_engine = get_relational_engine()

    async with db_engine.get_async_session() as session:
        user = (
            await session.execute(
                select(User)
                .options(selectinload(User.roles), selectinload(User.tenants))
                .where(User.id == user_id)
            )
        ).scalar()

        if not user:
            raise EntityNotFoundError(message=f"Could not find user: {user_id}")

        return user