El job que no corrió no produce ningún fallo
Los jobs de la noche reportan fallos y se quedan en silencio sobre el éxito, lo que suena eficiente hasta la mañana en que un job no arranca. El silencio entonces significa lo que significó en cada noche buena, y el hueco se encuentra días después por quien nota los datos faltantes.
Un informe matutino armado a partir de una lista esperada, no de eventos recibidos, atrapa eso. La pregunta no es qué jobs fallaron, sino qué jobs no reportaron en absoluto.
La duración pertenece al mismo informe. Un job que normalmente toma veinte minutos y tomó tres horas tuvo éxito, y algo está mal.
Leído una vez al empezar el día, un informe así reemplaza el ritual de abrir cuatro consolas para confirmar que nada necesita atención. Si algo la necesita, lo dice en la primera línea.
Cómo se ejecuta el ActionFlow en el lienzo
Los registros de jobs los lee un nodo HTTP Request de tu scheduler en un trigger Start Scheduled programado para correr después de que cierra la ventana nocturna.
Un nodo Loop recorre la lista de jobs esperados que declaras, y un nodo If dentro marca cualquier job sin registro alguno como no corrió. Un informe impulsado por fallos no puede producir ese caso.
Un nodo Math compara cada duración contra el promedio móvil propio de ese job, y un nodo Filter marca cualquier cosa fuera de tu tolerancia.
Un nodo Switch ordena los resultados en cuatro grupos (no corrió, falló, corrió largo, tuvo éxito) en el orden en que una persona quiere leerlos.
Un nodo Generate Text escribe el informe, nombra los primeros tres grupos de forma individual y reduce el cuarto a un conteo y una línea.
Un nodo Create Excel produce el registro para quien sigue la fiabilidad en el tiempo, y un nodo PostgreSQL guarda la ejecución para que los promedios de mañana sigan siendo reales.
Un nodo Slack publica el informe a la hora que eliges, y un nodo Email lo envía a quien posee los pipelines de datos, no a todo el equipo.
Nodos que usa este ActionFlow
- Start Scheduled (Start): se ejecuta después de que cierra la ventana nocturna.
- HTTP Request (Util): registros de jobs de tu scheduler.
- Loop (Control) con If (Control): recorre una lista esperada, para que un job que nunca corrió sea visible.
- Math (Util): duración contra el promedio móvil propio de cada job.
- Switch (Control): no corrió, falló, corrió largo, tuvo éxito.
- Generate Text (AI Core): el informe, con los éxitos reducidos a un conteo.
- PostgreSQL (Data): guarda la ejecución para que los promedios sigan siendo reales.
- Slack (Communication) con Email (Communication): el canal del equipo, y el dueño del pipeline.
Preguntas frecuentes
Empieza a crear flujos de IA
Crea una cuenta gratuita, abre una plantilla o un lienzo en blanco y ejecuta tu primer ActionFlow.
Boletín
Recibe actualizaciones del producto
Nodos nuevos, agents y notas de producto. Solo enviamos correo cuando merece la pena abrirlo.