import asyncio
import os
from supabase import create_client
from dotenv import load_dotenv

load_dotenv()

SUPABASE_URL = os.environ.get("SUPABASE_URL")
SUPABASE_KEY = os.environ.get("SUPABASE_SERVICE_ROLE_KEY") or os.environ.get("SUPABASE_KEY")
client = create_client(SUPABASE_URL, SUPABASE_KEY)

async def check_clusters():
    res = client.table("profiles").select("id, cluster_label").limit(10).execute()
    if not res.data:
        print("No profiles found")
        return
        
    print("Sample Cluster Labels:")
    for row in res.data:
        print(f"  - ID: {row['id']} | Label: {row['cluster_label']}")

if __name__ == "__main__":
    asyncio.run(check_clusters())