delete exixting schema

app/db.py

@@ -85,7 +85,13 @@ def transactional_conn(org_id: str):
     finally:
         conn.close()
 
-
+def delete_problematic_schema_versions_table(conn: duckdb.DuckDBPyConnection):
+    """
+    🔥 DEV ONLY: Brutally drops schema_versions table to fix corrupted INTEGER PK schema.
+    Run ONCE via API endpoint, then REMOVE this function from codebase.
+    """
+    conn.execute("DROP TABLE IF EXISTS main.schema_versions")
+    print("[delete] 🔥 Dropped main.schema_versions (dev wipe)")
 # ==================== SCHEMA EVOLUTION ==================== #
 def ensure_raw_table(conn: duckdb.DuckDBPyConnection):
     """
@@ -122,7 +128,7 @@ def ensure_schema_versions_table(conn: duckdb.DuckDBPyConnection):
     conn.execute("CREATE SCHEMA IF NOT EXISTS main")
     conn.execute("""
         CREATE TABLE IF NOT EXISTS main.schema_versions (
-            version_id INTEGER PRIMARY KEY,
+            version_id BIGINT GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
             table_name VARCHAR NOT NULL,
             schema_json JSON NOT NULL,
             created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,

app/main.py

@@ -131,6 +131,20 @@ app = FastAPI(
     }
 )
 
+@app.post("/api/v1/admin/wipe-schema")
+def wipe_schema_versions_table(org_id: str = Query(..., description="Organization ID")):
+    """
+    🔥 DEV ONLY: Emergency wipe of schema_versions table.
+    USE ONCE PER ORG, THEN REMOVE THIS ENDPOINT IMMEDIATELY.
+    """
+    try:
+        from app.db import get_conn, delete_problematic_schema_versions_table
+        conn = get_conn(org_id)
+        delete_problematic_schema_versions_table(conn)
+        conn.close()
+        return {"status": "wiped", "message": "schema_versions deleted. Remove this endpoint now."}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
 # ─── Request ID Middleware ─────────────────────────────────────────────────────
 @app.middleware("http")
 async def add_request_tracking(request: Request, call_next):