scripts/check_evidently_drift.py

import sys
from pathlib import Path

PROJECT_ROOT = Path(__file__).resolve().parents[1]
sys.path.insert(0, str(PROJECT_ROOT))

from app.drift_monitor import DriftMonitor


def main():
    reference_data_path = PROJECT_ROOT / "data" / "processed" / "train_final.csv"

    monitor = DriftMonitor(
        str(reference_data_path),
        batch_size=30,
    )

    for i in range(30):
        sample = {
            "AMT_INCOME_TOTAL": 100000.0 + i * 1000,
            "AMT_CREDIT": 400000.0 + i * 5000,
            "DAYS_BIRTH": -12000 - i,
            "DAYS_EMPLOYED": -2000 - i,
            "prediction": 0,
            "probability_of_default": 0.42,
            "risk_category": "Medium",
        }
        monitor.add_prediction(sample)

    print("Drift monitor executed")
    print(monitor.get_drift_summary())


if __name__ == "__main__":
    main()