import asyncio
from sqlmodel import create_engine, text

DATABASE_URL = "postgresql://pragativeer_admin:local_secure_password_2026@postgres:5432/pragativeer_prod"
engine = create_engine(DATABASE_URL)

with engine.connect() as conn:
    result = conn.execute(text("SELECT email, tier FROM \"user\" LIMIT 10;"))
    print(result.fetchall())