async def read_user_organization(
    *,
    db: AsyncSession = Depends(deps.get_db),
    current_user: User = Depends(deps.get_user),
) -> schemas.Organization:
    """Get the organization of the current user.

    Args:
    ----
        db (AsyncSession): The database session.
        current_user (User): The current user.

    Returns:
    -------
        schemas.Organization: The organization object.

    Raises:
    ------
        HTTPException: If the organization is not found.
    """
    if not current_user.organization_id:
        raise HTTPException(status_code=404, detail="User has no organization associated")

    # Use direct query to bypass permission checks
    stmt = select(OrganizationModel).where(OrganizationModel.id == current_user.organization_id)
    result = await db.execute(stmt)
    org = result.scalar_one_or_none()

    if not org:
        raise HTTPException(status_code=404, detail="Organization not found")

    # Return a dict with all required fields for Organization schema
    return schemas.Organization(
        id=org.id,
        name=org.name,
        description=org.description or "",
        created_at=org.created_at,
        modified_at=org.modified_at,
    )
Get the organization of the current user.

    Args:
    ----
        db (AsyncSession): The database session.
        current_user (User): The current user.

    Returns:
    -------
        schemas.Organization: The organization object.

    Raises:
    ------
        HTTPException: If the organization is not found.
    
backend/airweave/api/v1/endpoints/users.py