Class Escalations

Escalation queue — the canonical signal-pause surface for HotMesh workflows.

public.hmsh_escalations is a global Postgres table written by both the YAML DAG hook activity and Durable.workflow.condition(). Any consumer can interact with the queue using just a Postgres connection — no Durable dependency required.

Quick Start

import { Escalations } from '@hotmeshio/hotmesh';
import { Client as Postgres } from 'pg';

const client = new Escalations.Client({
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' },
  },
});

// List all available approvals for the 'manager' role
const pending = await client.list({ role: 'manager', available: true });

// Claim one atomically
const result = await client.claimByMetadata({
  key: 'orderId', value: 'order-123',
  assignee: 'alice@company.com',
  roles: ['manager', 'senior-manager'],
});

// Resolve and resume the waiting workflow in one round-trip
if (result.ok) {
  await client.resolve({ id: result.entry.id, resolverPayload: { approved: true } });
}
Copy