import asyncio
from database.postgres_pool import pool_wrapper

async def f():
    await pool_wrapper.init_all()
    rows = await pool_wrapper.execute_query_async("SELECT DISTINCT anchor_category FROM dashboard_canifa.chatbot_fashion_rules")
    print([r['anchor_category'] for r in rows])
    await pool_wrapper.close_all()

asyncio.run(f())
