server/scripts/migrate_v2_part2.py

import os
import sys
from sqlalchemy import create_engine, text

current_dir = os.path.dirname(os.path.abspath(__file__))
parent_dir = os.path.dirname(current_dir)
sys.path.append(parent_dir)

from app.core.config import settings

def migrate_v2_part2():
    print("🚀 Starting V2 Migration Part 2...")
    engine = create_engine(settings.DATABASE_URL)
    
    with engine.connect() as conn:
        print("Adding is_emergency to chat_messages...")
        try:
            conn.execute(text("ALTER TABLE chat_messages ADD COLUMN is_emergency BOOLEAN DEFAULT FALSE"))
            print("✅ Added is_emergency column")
        except Exception as e:
            print(f"⚠️  is_emergency might already exist: {e}")
            
        conn.commit()
    
    print("✅ Migration Part 2 Complete!")

if __name__ == "__main__":
    migrate_v2_part2()