Skip to content

@saflib/jobs-spec


Interface: components

Properties

headers

headers: never


parameters

parameters: never


pathItems

pathItems: never


requestBodies

requestBodies: never


responses

responses: never


schemas

schemas: object

error

error: object

error.code?

optional code: string

Description

A short, machine-readable error code, for when HTTP status codes are not sufficient.

error.message?

optional message: string

Description

A human-readable description of the error.

Example
ts
The requested resource could not be found.

job

job: object

Description

Wire form of a queued API-call job; field names match the job row and nested JSON. Omits internal columns (heartbeat_at, updated_at). Authority is the discriminated evidence grant without the raw enqueue assertion token (detail endpoints may return that separately as authority_assertion).

job.attempt

attempt: number

Description

Number of delivery attempts consumed so far (0 before first claim).

Example
ts
0;
job.authority

authority: { kind: "request"; request_id: string; user_id: string; } | { kind: "resource"; resource_id: string; resource_kind: string; user_id: string; } | { cron_job_name: string; kind: "cron"; user_id: string; }

Type declaration

{ kind: "request"; request_id: string; user_id: string; }

{ kind: "resource"; resource_id: string; resource_kind: string; user_id: string; }

{ cron_job_name: string; kind: "cron"; user_id: string; }

Description

Root grant for the job chain (copied verbatim by children). Discriminated on kind. Wire form excludes the embedded enqueue assertion token.

job.concurrency_key

concurrency_key: null | string

Description

Optional key limiting concurrency: at most one running job per key (e.g. matter:{id}).

Example
ts
matter: demo - 1;
job.created_at

created_at: string

Format: date-time

Description

When the job row was created.

Example
ts
2026-08-06T20:59:55.000Z
job.dedupe_key

dedupe_key: null | string

Description

Optional key unique among non-terminal jobs. Re-enqueue with the same live key upserts (pushes run_at, refreshes request) and returns the existing job.

Example
ts
matter:demo-1:claim
job.enqueued_by_operation_id

enqueued_by_operation_id: string

Description

Calling operationId that enqueued this job (trigger-map edge).

Example
ts
startJobsDemo;
job.finished_at

finished_at: null | string

Format: date-time

Description

When the job reached a terminal status; null while still active.

Example
ts
null;
job.id

id: string

Description

Short identifier for the job (from generateShortId).

Example
ts
Jb3k_mN7;
job.max_attempts

max_attempts: number

Description

Maximum delivery attempts before the job becomes dead (exhausted).

Example
ts
5;
job.operation_id

operation_id: string

Description

Target OpenAPI operationId resolved at delivery time.

Example
ts
jobsDemoStepB;
job.original_request_id

original_request_id: string

Description

Chain-root request id (user request / webhook X-Request-ID, or cron-tick id). Copied from parent on chained enqueues; joins audit_event.request_id.

Example
ts
r - abc123;
job.parent_job_id

parent_job_id: null | string

Description

Short id of the job that enqueued this one, or null at the chain root.

Example
ts
null;
job.priority

priority: number

Description

Claim priority; higher values are claimed first. Default 0.

Example
ts
0;
job.request

request: object

Description

Capped request payload delivered to the target operation (serialized size ≤ 16 KB). Path params, query, and body are optional and substituted into the operation's path template / request.

Example
ts
{
             *       "body": {
             *         "failures_before_success": 2
             *       }
             *     }
job.request.body?

optional body: unknown

Description

JSON request body for the target operation, when any.

job.request.path_params?

optional path_params: object

Index Signature

[key: string]: unknown

Description

Path template substitutions keyed by parameter name.

job.request.query?

optional query: object

Index Signature

[key: string]: unknown

Description

Query string parameters keyed by name.

job.result

result: null | { error_body?: null | string; status_code?: number; terminal_reason?: null | "exhausted" | "permanent-status" | "rejected-by-endpoint" | "auth-unresolvable" | "cancelled-by-admin" | "cancelled-by-chain"; }

Type declaration

null

{ error_body?: null | string; status_code?: number; terminal_reason?: null | "exhausted" | "permanent-status" | "rejected-by-endpoint" | "auth-unresolvable" | "cancelled-by-admin" | "cancelled-by-chain"; }

Description

Outcome of the latest terminal or failed attempt. Null while the job has not yet finished an attempt that records a result. error_body is set only on failure and capped at 8 KB.

job.run_at

run_at: string

Format: date-time

Description

Earliest time the job may be claimed for delivery.

Example
ts
2026-08-06T21:00:00.000Z
job.started_at

started_at: null | string

Format: date-time

Description

When the current (or last) delivery attempt started; null if never claimed.

Example
ts
null;
job.status

status: "pending" | "running" | "retrying" | "succeeded" | "dead" | "cancelled"

Description

Lifecycle state. pending/retrying are claimable; running is in delivery; succeeded/dead/cancelled are terminal.

Example
ts
pending
@enum {string}
job.user_id

user_id: string

Description

Acting user whose authority the job runs under.

Example
ts
Us7k_pQ2;