Interface MigrateEscalationParams

Full-fidelity migration params. Extends CreateEscalationParams with:

  • id (required) — preserves the original UUID; no auto-generation
  • lifecycle state fields (status, assignedTo, claimExpiresAt, …) — carry over the exact state of the migrated row so in-flight escalations land correctly
  • createdAt / updatedAt — preserve original timestamps

The underlying INSERT uses ON CONFLICT (id) DO NOTHING, so calling migrate() multiple times with the same ID is safe — subsequent calls return null without touching the existing row.

interface MigrateEscalationParams {
    accumulate?: AccumulateConfig;
    appId?: string;
    assignedTo?: string;
    assignee?: string;
    batch?: string[];
    claimedAt?: Date;
    claimExpiresAt?: Date;
    createdAt?: Date;
    createdBy?: string;
    description?: string;
    durationMinutes?: number;
    entity?: string;
    envelope?: Record<string, unknown>;
    escalationPayload?: Record<string, unknown>;
    expiresAt?: Date;
    id: string;
    initiatedBy?: string;
    metadata?: Record<string, unknown>;
    milestones?: {
        name: string;
        value: unknown;
        [key: string]: unknown;
    }[];
    namespace?: string;
    originId?: string;
    parentId?: string;
    partialOnTimeout?: boolean;
    priority?: number;
    resolvedAt?: Date;
    resolverPayload?: Record<string, unknown>;
    role?: string;
    signalKey?: string;
    spanId?: string;
    status?:
        | "pending"
        | "claimed"
        | "resolved"
        | "cancelled"
        | "expired";
    subtype?: string;
    taskId?: string;
    taskQueue?: string;
    topic?: string;
    traceId?: string;
    type?: string;
    updatedAt?: Date;
    workflowId?: string;
    workflowType?: string;
}

Hierarchy (view full)

Properties

accumulate? appId? assignedTo? assignee? batch? claimedAt? claimExpiresAt? createdAt? createdBy? description? durationMinutes? entity? envelope? escalationPayload? expiresAt? id initiatedBy? metadata? milestones? namespace? originId? parentId? partialOnTimeout? priority? resolvedAt? resolverPayload? role? signalKey? spanId? status? subtype? taskId? taskQueue? topic? traceId? type? updatedAt? workflowId? workflowType?

Properties

Optionalaccumulate

accumulate?: AccumulateConfig

Declares the row as an open accumulator. See ConditionQueueConfig.accumulate. Standalone rows (no signalKey) accumulate and complete identically; the wake is a no-op.

OptionalappId

appId?: string

OptionalassignedTo

assignedTo?: string

Optionalassignee

assignee?: string

Born-assigned: writes assigned_to in the creation INSERT. See ConditionQueueConfig.assignee for the two modes (durable pre-assignment vs. hard claim with durationMinutes).

Optionalbatch

batch?: string[]

Declares the row as a batch accumulator. See ConditionQueueConfig.batch. Standalone batch rows (no signalKey) accumulate and complete identically; the wake is a no-op.

OptionalclaimedAt

claimedAt?: Date

OptionalclaimExpiresAt

claimExpiresAt?: Date

OptionalcreatedAt

createdAt?: Date

OptionalcreatedBy

createdBy?: string

Optionaldescription

description?: string

OptionaldurationMinutes

durationMinutes?: number

With assignee, arms the claim TTL window at creation. See ConditionQueueConfig.durationMinutes.

Optionalentity

entity?: string

Optionalenvelope

envelope?: Record<string, unknown>

OptionalescalationPayload

escalationPayload?: Record<string, unknown>

OptionalexpiresAt

expiresAt?: Date

id

id: string

Required — preserve the original UUID from the source table.

OptionalinitiatedBy

initiatedBy?: string

Optionalmetadata

metadata?: Record<string, unknown>

Optionalmilestones

milestones?: {
    name: string;
    value: unknown;
    [key: string]: unknown;
}[]

Optionalnamespace

namespace?: string

OptionaloriginId

originId?: string

OptionalparentId

parentId?: string

OptionalpartialOnTimeout

partialOnTimeout?: boolean

See ConditionQueueConfig.partialOnTimeout.

Optionalpriority

priority?: number

OptionalresolvedAt

resolvedAt?: Date

OptionalresolverPayload

resolverPayload?: Record<string, unknown>

Optionalrole

role?: string

OptionalsignalKey

signalKey?: string

OptionalspanId

spanId?: string

Optionalstatus

status?:
    | "pending"
    | "claimed"
    | "resolved"
    | "cancelled"
    | "expired"

Optionalsubtype

subtype?: string

OptionaltaskId

taskId?: string

OptionaltaskQueue

taskQueue?: string

Optionaltopic

topic?: string

OptionaltraceId

traceId?: string

Optionaltype

type?: string

OptionalupdatedAt

updatedAt?: Date

OptionalworkflowId

workflowId?: string

OptionalworkflowType

workflowType?: string

Settings

Member Visibility

On This Page

Properties