Motores de workflows

Visión General

Los workflow engines orquestan procesos de negocio complejos de múltiples pasos que abarcan servicios, tiempo y dominios de falla. A diferencia de simples job queues que ejecutan tareas independientes, los workflows gestionan transiciones de estado, retries, timeouts y compensaciones a través de sistemas distribuidos. Ya sea procesando una orden de e-commerce, suscribiendo una póliza de seguro o aprobando un préstamo, los workflow engines aseguran que cada paso se ejecute en el orden correcto con manejo apropiado de errores.

Cuándo Usar

Usa este recurso cuando:

• Los procesos de negocio tienen 5+ pasos secuenciales con requisitos de manejo de fallas
• Los pasos necesitan esperar aprobación humana o eventos externos (horas o días)
• Las fallas parciales requieren transacciones compensatorias (patrón saga)
• Necesitas audit trails y visibilidad del estado de procesos de larga duración

Solución

Temporal Workflow (TypeScript)

import { Workflow, Activity } from '@temporalio/workflow';

const { sendEmail, chargePayment, shipOrder } = proxyActivities<{
  sendEmail(email: string): Promise<void>;
  chargePayment(amount: number): Promise<string>;
  shipOrder(orderId: string): Promise<string>;
}>({
  startToCloseTimeout: '30 seconds',
  retry: { maximumAttempts: 3 }
});

export async function orderWorkflow(order: Order): Promise<void> {
  await sendEmail(order.customerEmail);

  const paymentId = await chargePayment(order.total);
  if (!paymentId) {
    await sendCompensationEmail(order);
    throw new Error('Payment failed');
  }

  try {
    await shipOrder(order.id);
  } catch (err) {
    await refundPayment(paymentId);
    throw err;
  }

  await sendEmail(order.customerEmail, 'Order shipped!');
}

State Machine (Python + transitions)

from transitions import Machine

class OrderWorkflow:
    states = ['pending', 'paid', 'shipped', 'cancelled']

    def __init__(self):
        self.machine = Machine(
            model=self,
            states=OrderWorkflow.states,
            initial='pending',
            transitions=[
                {'trigger': 'pay', 'source': 'pending', 'dest': 'paid'},
                {'trigger': 'ship', 'source': 'paid', 'dest': 'shipped'},
                {'trigger': 'cancel', 'source': ['pending', 'paid'], 'dest': 'cancelled',
                 'after': 'refund_payment'}
            ]
        )

    def refund_payment(self):
        print("Refunding payment...")

order = OrderWorkflow()
order.pay()      # pending -> paid
order.ship()     # paid -> shipped

Camunda BPMN Process

<?xml version="1.0" encoding="UTF-8"?>
<bpmn:definitions>
  <bpmn:process id="OrderProcess" isExecutable="true">
    <bpmn:startEvent id="StartEvent" />
    <bpmn:sequenceFlow id="Flow_1" sourceRef="StartEvent" targetRef="CheckInventory" />
    
    <bpmn:serviceTask id="CheckInventory" camunda:delegateExpression="${inventoryChecker}" />
    <bpmn:sequenceFlow id="Flow_2" sourceRef="CheckInventory" targetRef="Gateway_1" />
    
    <bpmn:exclusiveGateway id="Gateway_1" default="Flow_4">
      <bpmn:sequenceFlow id="Flow_3" sourceRef="Gateway_1" targetRef="ProcessPayment"
                         conditionExpression="${inventoryAvailable}" />
      <bpmn:sequenceFlow id="Flow_4" sourceRef="Gateway_1" targetRef="NotifyOutOfStock" />
    </bpmn:exclusiveGateway>
  </bpmn:process>
</bpmn:definitions>

Explicación

Conceptos core:

• Definición de workflow: El blueprint que describe pasos, transiciones y condiciones
• Activity: Una única unidad de trabajo (llamada a API, update de base de datos, tarea humana)
• Estado: La posición actual en el workflow (persistido para durabilidad)
• Compensación: Revertir pasos ya completados cuando un paso posterior falla
• Timer: Retrasar ejecución o establecer deadlines para activities

Cuándo usar workflow engines vs. código:

Complejidad	Enfoque	Ejemplo
1-2 pasos	Direct function calls	Enviar email de bienvenida
3-5 pasos	Código con retry logic	Procesamiento de orden con pago
5+ pasos	Workflow engine	Aprobación de préstamo con 10+ departamentos
Tareas humanas	BPMN engine	Revisión de claim de seguro

Variantes

Engine	Modelo	Ideal Para
Temporal	Code-as-workflow	Centrado en developers; durable execution
Camunda	BPMN	Visibilidad de business analysts; tareas humanas
Apache Airflow	DAGs	Data pipelines; workflows programados
Netflix Conductor	JSON DSL	Orquestación de microservicios
AWS Step Functions	State machines	Serverless; integración AWS

Lo que funciona

• Activities idempotentes: Ejecutar la misma activity dos veces debería producir el mismo resultado. Consulta idempotencia de mensajes.
• Claves de idempotencia: Pasar keys únicas a APIs externas para prevenir double charges
• Set timeouts en todo: Timeout default de 10 minutos previene workflows stuck
• Versiona definiciones de workflow: Nuevos despliegues no deberían romper workflows en vuelo
• Query estado de workflow: Expón APIs para verificar progreso sin inspeccionar estado interno

Errores Comunes

1. Acoplamiento fuerte al orchestrator: Lógica de negocio filtrándose en definiciones de workflow dificulta testing
2. Sin paths de compensación: Workflows fallados que ya cobraron al cliente necesitan refunds explícitos. Aprende más en patrón saga.
3. Polling en lugar de events: Esperar 30 segundos para check de status desperdicia recursos; usa callbacks
4. Ignorar historial de workflow: Workflows completados viejos llenan storage; implementa retention policies
5. No testear replay: Temporal y similares hacen replay de historial; código no determinístico se rompe