@lucid-softworks/queue-workflow

Runs a typed workflow definition as a durable queue handler.

import { createQueueWorkflowHandler } from "@lucid-softworks/queue-workflow";

const handlers = {
  workflow: createQueueWorkflowHandler(definition, { checkpointStore }),
};

The queue job id becomes the workflow execution id, enabling checkpoint resume on at-least-once delivery. Queue cancellation is forwarded structurally to the workflow signal. The handler result is a readonly record of task outputs.