import asyncio
from server import async_session
from sqlalchemy import text

async def test():
    try:
        async with async_session() as session:
            result = await session.execute(text('SELECT 1'))
            print('DB OK:', result.fetchone())
    except Exception as e:
        print('DB Error:', e)

asyncio.run(test())