QueueHandler

import type { QueueHandler } from "@elie-laloum/outpost";

Parameters and properties

inputRequired
WorkflowJson
JSON input from the job’s request.
contextRequired
QueueHandlerContext
Idempotency key, abort signal and claimed job.

Returns

QueueResult | Promise<QueueResult>

Signature

export type QueueHandler = (
  input: WorkflowJson,
  context: QueueHandlerContext,
) => Promise<QueueResult> | QueueResult;