from sqlalchemy import Column, Integer, String, DateTime, Enum, Text from datetime import datetime from app.core.database import Base class VasSlotRefreshStatus(Base): __tablename__ = "vas_slot_refresh_status" id = Column(Integer, primary_key=True, autoincrement=True) routing_key = Column(String(255), nullable=False, unique=True) snapshot_source = Column( Enum('worker', 'manual', 'sync'), nullable=False ) country = Column(String(100), nullable=False) city = Column(String(100), nullable=False) visa_type = Column(String(100), nullable=False) last_refresh_at = Column(DateTime, nullable=False) last_success_at = Column(DateTime) last_error = Column(Text) updated_at = Column( DateTime, nullable=False, default=datetime.utcnow, onupdate=datetime.utcnow )