Pipeline studio

El Pipeline Studio (/space/studio) es el orquestador visual de workflows. Donde el chat es por turnos, el studio es por grafos: compones agentes y pasos como nodos conectados por aristas, y luego ejecutas todo el grafo con enrutado condicional, hand-offs y triggers programados.

¿Nuevo en el lado de IA? Lee primero Conceptos de IA desde cero — Salida estructurada / extracción de plan es lo que convierte una respuesta de chat en este grafo.

El modelo de workflow

Los workflows se persisten en Postgres (workflows, workflow_nodes, workflow_edges, workflow_runs en schema.ts):

• Workflow — nombre + usuario propietario (opcionalmente vinculado a una conversación).
• Nodos — pasos del grafo (llamadas de agente, herramientas, compuertas).
• Aristas — conexiones dirigidas entre nodos (éxito, fallo, condicional).
• Runs — instancias de ejecución con estado e historial de pasos.

El canvas

WorkflowStudio renderiza un canvas interactivo (workflow-canvas.tsx, workflow-visualizer.tsx, workflow-nodes.tsx):

• Drag & drop de colocación de nodos y conexión de aristas.
• Configuración por nodo — qué agente/modelo corre, qué herramientas puede usar, entradas y salidas.
• Compuertas de aprobación — approval-card.tsx inserta checkpoints humano-en-el-bucle antes de acciones destructivas o externas.
• Modo edición para autoral, modo vista para inspeccionar un plan ejecutado.

Los conceptos detrás del studio

El studio hace tangibles dos ideas de IA:

• Salida estructurada. El plan del orquestador no es prosa libre — se recupera como un objeto con forma de esquema (pasos, dependencias) vía un escáner JSON tolerante más validación estricta con Zod. Ese dato estructurado es lo que se puede renderizar como nodos y aristas del grafo; el texto libre no. Ver Conceptos de IA → Salida estructurada.
• Orquestación de agentes como grafo. Ejecutar un workflow es la misma maquinaria multi-agente que el chat — orchestrators, executors, verifiers — pero dispuesta como un grafo de dependencias explícito en lugar de un diálogo turno a turno. Las aristas condicionales son puntos de decisión; los hand-offs pasan trabajo entre agentes; las compuertas de aprobación son checkpoints humano-en-el-bucle antes de acciones destructivas/externas.

De dónde vienen los planes

El studio está fuertemente acoplado a la orquestación de chat:

1. El Lead Orchestrator planifica una tarea en el chat y emite un plan estructurado en su respuesta.
2. El cliente lo extrae con extractPlanFromContent → safeParsePlan (escáner JSON tolerante + validación Zod estricta en output-schemas.ts).
3. El plan extraído se puede abrir en el studio como grafo visual — los nodos se convierten en los pasos del plan, las aristas en las dependencias.

Este es el camino canónico: plan en el chat → refinar visualmente en el studio → ejecutar. La extracción es robusta ante la ausencia de fences de código y el wrapping en prosa, así que los planes sobreviven incluso cuando el modelo no los formatea perfectamente.

Ejecutar workflows

Los runs fluyen por workflow_runs con estado por paso. La ejecución de orquestación reutiliza la misma maquinaria de agentes que el chat (módulos agent: orchestrator, executors, verifiers), así que cada paso recibe el mismo seguimiento de uso por paso (tokens, coste, latencia) visible en el panel de ops y en las métricas de gobernanza.

Enrutado condicional y hand-offs

Las aristas pueden llevar condiciones — la salida de un paso enruta el siguiente (retry, escalado, continuar). Los hand-offs permiten que un agente pase trabajo a otro a mitad del grafo, que es como la jerarquía (orchestrator → executors → verifiers) se enchufa al modelo de pipeline.

Triggers programados

Los workflows se pueden programar vía Cron (/space/cron): en lugar de ejecuciones manuales, un trigger dispara el grafo según un horario. Ver la página Uso, salud y equipos para detalles de cron.

Superficies relacionadas

• Panel de ops del chat — estado por paso en vivo de una ejecución de orquestación.
• Jerarquía de agentes — el árbol de agentes en runtime que ejecuta los pasos.
• Cron — ejecución programada de pipelines.