Graph Compose: Flujos de Trabajo Temporales Alojados con Constructor Visual e IA

Graph Compose es una plataforma alojada para orquestar flujos de trabajo de API en el motor de ejecución duradero de Temporal. Defines flujos de trabajo como gráficos de nodos (llamadas HTTP, agentes de IA, iteradores, límites de error) que se ejecutan como flujos de trabajo de Temporal sin gestionar infraestructura.

Tres formas de construir el mismo gráfico

Cada flujo de trabajo utiliza un formato JSON consistente que se puede crear mediante:

• Un constructor visual React Flow
• Un SDK tipado de TypeScript (@graph-compose/client)
• Un asistente de IA que convierte inglés simple en un gráfico

Cómo funciona

Envías flujos de trabajo JSON a través de API a https://api.graphcompose.io/v1/workflows/execute y se ejecutan inmediatamente en Temporal alojado. Sin paso de despliegue, sin clúster de Temporal que ejecutar, sin trabajadores que desplegar. La plataforma maneja la programación, reintentos, límites de error y persistencia de estado.

Ejemplo de flujo de trabajo

const workflow = {
  "nodes": [
    {
      "id": "upload_image",
      "type": "http",
      "dependencies": [],
      "http": {
        "method": "PUT",
        "url": "https://storage.example.com/{{ context.filename }}",
        "headers": {
          "Content-Type": "{{ context.contentType }}",
          "Authorization": "Bearer {{ $secret('storage_token') }}"
        },
        "body": "{{ context.imageData }}"
      },
      "activityConfig": {
        "retryPolicy": {
          "maximumAttempts": 3,
          "initialInterval": "1s",
          "backoffCoefficient": 2
        },
        "startToCloseTimeout": "30 seconds"
      }
    },
    {
      "id": "generate_thumbnails",
      "type": "http",
      "dependencies": ["upload_image"],
      "http": {
        "method": "POST",
        "url": "https://images.example.com/process",
        "body": {
          "source": "{{ results.upload_image.data.url }}",
          "sizes": ["400x400", "200x200"]
        }
      }
    }
  ],
  "context": {
    "filename": "profile.jpg",
    "contentType": "image/jpeg"
  }
}

Características principales

• Ejecución duradera: Los flujos de trabajo sobreviven reinicios de servidor, fallos de red y caídas de procesos. Temporal reproduce desde el último punto de control.
• Reintentos automáticos: Configura políticas de reintento por nodo con intentos máximos, intervalos de retroceso y tipos de error no reintentables.
• Límites de error: Envuelve nodos en límites de error estilo try/catch con comportamiento de respaldo.
• Persistencia de estado: Consulta el estado del flujo de trabajo en cualquier punto.
• Expresiones de plantilla: Los nodos hacen referencia a resultados de nodos anteriores mediante la sintaxis {{ results.node_id.data.field }}.

Licencias

Modelo de código abierto: los fundamentos de ejecución y el servicio de integraciones son AGPL-3.0, mientras que el orquestador de plataforma, el constructor visual y el asistente de IA son propietarios.