Saltar al contenido principal

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