Skip to content

captureJobs

const captureJobs: PgTableWithColumns<{ columns: { attempt: PgColumn<{ baseColumn: never; columnType: "PgInteger"; data: number; dataType: "number"; driverParam: string | number; enumValues: undefined; generated: undefined; hasDefault: true; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "attempt"; notNull: true; tableName: "capture_jobs"; }, { }, { }>; buildId: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "build_id"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; cancelRequestedAt: PgColumn<{ baseColumn: never; columnType: "PgTimestampString"; data: string; dataType: "string"; driverParam: string; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "cancel_requested_at"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; createdAt: PgColumn<{ baseColumn: never; columnType: "PgTimestampString"; data: string; dataType: "string"; driverParam: string; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "created_at"; notNull: true; tableName: "capture_jobs"; }, { }, { }>; entry: PgColumn<{ baseColumn: never; columnType: "PgText"; data: CaptureJobEntry; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "entry"; notNull: true; tableName: "capture_jobs"; }, { }, { $type: CaptureJobEntry; }>; error: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "error"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; finishedAt: PgColumn<{ baseColumn: never; columnType: "PgTimestampString"; data: string; dataType: "string"; driverParam: string; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "finished_at"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; id: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: true; name: "id"; notNull: true; tableName: "capture_jobs"; }, { }, { }>; jobId: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "job_id"; notNull: true; tableName: "capture_jobs"; }, { }, { }>; kind: PgColumn<{ baseColumn: never; columnType: "PgText"; data: CaptureJobKind; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "kind"; notNull: true; tableName: "capture_jobs"; }, { }, { $type: CaptureJobKind; }>; maxAttempts: PgColumn<{ baseColumn: never; columnType: "PgInteger"; data: number; dataType: "number"; driverParam: string | number; enumValues: undefined; generated: undefined; hasDefault: true; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "max_attempts"; notNull: true; tableName: "capture_jobs"; }, { }, { }>; owner: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "owner"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; payload: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "payload"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; shardId: PgColumn<{ baseColumn: never; columnType: "PgText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "shard_id"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; startedAt: PgColumn<{ baseColumn: never; columnType: "PgTimestampString"; data: string; dataType: "string"; driverParam: string; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "started_at"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; status: PgColumn<{ baseColumn: never; columnType: "PgText"; data: "failed" | "cancelled" | "queued" | "running" | "done" | "expired"; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "status"; notNull: true; tableName: "capture_jobs"; }, { }, { $type: "failed" | "cancelled" | "queued" | "running" | "done" | "expired"; }>; updatedAt: PgColumn<{ baseColumn: never; columnType: "PgTimestampString"; data: string; dataType: "string"; driverParam: string; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "updated_at"; notNull: true; tableName: "capture_jobs"; }, { }, { }>; visibleAt: PgColumn<{ baseColumn: never; columnType: "PgTimestampString"; data: string; dataType: "string"; driverParam: string; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "visible_at"; notNull: false; tableName: "capture_jobs"; }, { }, { }>; }; dialect: "pg"; name: "capture_jobs"; schema: undefined; }>

Defined in: packages/db-postgres/src/schema/capture-job.ts:13

Narrow capture_jobs table definition: the database queue’s job rows and per-attempt claim rows. No foreign keys: notify jobs may have no build, and finished rows are purged by retention.