Saltearse al contenido
Nappai Documentation

In-Memory Checkpointer

El In-Memory Checkpointer actúa como una “caja de estado temporal” que guarda y recupera la información de tus flujos de trabajo únicamente en la memoria RAM de tu equipo. Su propósito principal es permitirte guardar el progreso de un proceso en un punto específico y retomarlo después, todo ello de forma ultra rápida y sin escribir datos en el disco duro. Es ideal para depurar flujos, probar automatizaciones o gestionar procesos cortos donde la velocidad es más importante que el almacenamiento permanente.

¿Cómo funciona?

Internamente, este componente mantiene una “agenda” en memoria RAM indexada por un identificador único. Cuando lo ejecutas, toma el State (el estado actual de tus datos), los Metadata (información extra como fechas o versiones) y los organiza bajo una Checkpoint Key (nombre identificador). La información se guarda instantáneamente en memoria. Si en un paso posterior necesitas recuperar ese estado, solo debes indicar la misma clave y el componente te devolverá exactamente lo que guardaste. Si decides que ya no lo necesitas, puedes solicitar que limpie esa memoria para liberar espacio.

Al ser un componente en fase de desarrollo activo (is_development), su funcionamiento está optimizado para flujos iterativos y depuración. Ten en cuenta que no guarda nada en archivos o disco: si se reinicia el servidor, el motor de ejecución o el navegador, la memoria se limpia automáticamente y los datos se pierden.

Entradas

Campos de Entrada

Los siguientes campos están disponibles para configurar este componente:

  • State: Representa el estado actual o el fragmento de datos de tu flujo que deseas guardar. Por defecto, se espera que proporciones explícitamente la información que quieres almacenar.
  • Metadata: Un contenedor para información contextual adicional, como fechas de creación, identificadores de ejecución o etiquetas de seguimiento. Si no agregas nada, el campo se inicia vacío por defecto.
  • Checkpoint Key: Es el identificador único que usarás para nombrar y recuperar el estado guardado. Puedes dejarlo en blanco para que el sistema genere una clave automática, o escribir una propia para mantener un orden lógico en tu flujo.

Salidas

El componente devuelve información clave para que puedas verificar que todo funcionó correctamente y continuar tu flujo sin interrupciones:

  • Saved Checkpoint: El estado restaurado o referenciado, listo para ser consumido por los siguientes nodos.
  • Operation Status: Un mensaje de texto ("saved", "loaded", "success", "error") que confirma si la operación se realizó o si hubo un problema.
  • Updated Metadata: Los metadatos actualizados o confirmados, útiles para mantener un registro limpio y fácil de auditar.
  • Checkpointer: Una referencia directa al gestor de estado, que otros nodos pueden usar para acceder a este registro sin volver a configurarlo.

Ejemplo de Respuesta JSONjson

{ “Saved Checkpoint”: { “execution_context”: { “step”: 2, “status”: “processing”, “values”: [10, 20] }, “timestamp”: “2024-05-20T10:15:00Z” }, “Operation Status”: “saved”, “Updated Metadata”: { “version”: “1.0”, “execution_id”: “exec_9a8b7c”, “last_updated”: “2024-05-20T10:15:00Z” }, “Checkpointer”: { “type”: “InMemoryCheckpointer”, “ready”: true } } Estas salidas te permiten continuar automáticamente con el siguiente paso del flujo, verificar si la operación fue exitosa o rastrear los metadatos para debugging. El campo Checkpointer actúa como un enlace directo para que otros nodos accedan a este gestor de estado.

Conectividad

Este componente suele conectarse a nodos que gestionan el flujo de control (como bifurcaciones, bucles o condicionales) para validar si el estado se guardó correctamente antes de continuar. También se enlaza frecuentemente con componentes de State Management, Agent Loops o Debug/Logging Nodes que necesitan consultar el estado anterior o reanudar un proceso interrumpido. La conexión lógica es siempre hacia adelante en el flujo, alimentando a los siguientes pasos con el contexto restaurado y permitiendo que la automatización “recuerde” dónde se quedó.

Ejemplo de Uso

Imagina que estás automatizando el procesamiento de datos con un asistente de IA, pero a veces el proceso se interrumpe por un error de red o un límite de tiempo. Puedes conectar este componente en un paso crítico para guardar el State actual usando una Checkpoint Key como "proc_data_step1". Si el flujo falla, en lugar de empezar desde cero, un nodo de reintento o un bucle puede usar el mismo identificador para recuperar el Saved Checkpoint y continuar exactamente desde donde se quedó. Esto acelera las pruebas, evita perder avances en flujos iterativos y hace mucho más sencillo identificar en qué paso ocurren los errores.

Consejos y Mejores Prácticas

  • Utiliza este componente preferentemente para flujos de corta duración, depuración o pruebas unitarias donde la velocidad de respuesta es prioritaria.
  • Dado que opera en memoria RAM, los datos desaparecerán si reinicias el servicio o el servidor. No lo uses para almacenar información crítica a largo plazo.
  • Aprovecha el campo Metadata para agregar etiquetas de seguimiento (ej. {"user": "admin", "cycle": 3}), lo que facilitará la auditoría y el debugging sin afectar el rendimiento.
  • Como está en fase de desarrollo activo, verifica la documentación oficial antes de integrarlo en producción, ya que su API podría recibir ajustes menores.

Consideraciones de Seguridad

Al no escribir datos en disco, este componente reduce el riesgo de exposición de información sensible en archivos temporales o logs persistentes. Sin embargo, ten en cuenta que la memoria RAM es accesible por el proceso en ejecución; para entornos de alta seguridad, complementa su uso con validaciones de estado en los nodos subsiguientes y asegúrate de limpiar la memoria cuando ya no necesites los datos para evitar acumulación innecesaria.