webapp/app/models/slot_refresh_status.py

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
    )