Capítulo 3: Entrenamiento Continuo
Disparadores de Reentrenamiento
Pipeline de Reentrenamiento Automatizado
# continuous_training.py
from datetime import datetime, timedelta
def check_retraining_triggers():
triggers = []
# Check performance
current_auc = get_production_metrics()['auc_roc']
if current_auc < 0.82:
triggers.append(('performance', current_auc))
# Check data drift
drift_score = calculate_drift_score()
if drift_score > 0.15:
triggers.append(('drift', drift_score))
# Check schedule (30 days since last training)
last_training = get_last_training_date()
if datetime.now() - last_training > timedelta(days=30):
triggers.append(('schedule', last_training))
return triggers
def main():
triggers = check_retraining_triggers()
if triggers:
print(f"Retraining triggered by: {triggers}")
run_training_pipeline()
Siguiente: Cuestionario del Módulo 8