Add configurable job timeouts and rename processingInterval to pollInterval

Author: noxify

.changeset/timeout-and-poll-interval.md

@@ -0,0 +1,58 @@
+---
+"@vorsteh-queue/core": minor
+"@vorsteh-queue/adapter-drizzle": minor
+"@vorsteh-queue/adapter-prisma": minor
+---
+
+Add configurable job timeouts and rename `processingInterval` to `pollInterval`.
+
+**New Features:**
+
+- **Configurable job timeouts**: Set `timeout: number` for specific timeout or `timeout: false` to disable timeout completely
+- **Job-specific timeout override**: Individual jobs can override queue default timeout settings
+- **Timeout field storage**: Job timeout configuration is now stored in job records for proper handling
+
+**Breaking Changes:**
+
+- **Renamed `processingInterval` to `pollInterval`**: More accurately describes the interval between queue polling cycles
+- **Database schema changes**: Added `timeout` column to queue_jobs table (JSONB field, nullable)
+
+**Migration Guide:**
+
+```typescript
+// Before
+const queue = new Queue(adapter, {
+  name: "my-queue",
+  processingInterval: 1000, // OLD
+})
+
+// After
+const queue = new Queue(adapter, {
+  name: "my-queue",
+  pollInterval: 1000, // NEW
+})
+
+// New timeout features
+await queue.add("long-job", payload, { timeout: false }) // Disable timeout
+await queue.add("quick-job", payload, { timeout: 5000 }) // 5 second timeout
+```
+
+**Database Migration Required:**
+
+- **Drizzle users**: Run migrations to add `timeout` column
+- **Prisma users**: Run `prisma db push` or `prisma migrate` to apply schema changes
+
+**Examples:**
+
+```typescript
+// Disable timeout for long-running data processing
+await queue.add("process-large-dataset", data, { timeout: false })
+
+// Set specific timeout for API calls
+await queue.add("external-api-call", params, { timeout: 30000 })
+
+// Use default timeout (30 seconds) - no change needed
+await queue.add("normal-job", payload)
+```
+
+This release improves queue configuration clarity and provides flexible timeout control for different job types.

.github/workflows/ci.yml

@@ -100,12 +100,12 @@ jobs:
         run: pnpm test:core
 
       - name: Test Drizzle PostgreSQL (PGlite)
-        run: pnpm test:drizzle-postgres
+        run: pnpm test:drizzle
 
       - name: Test Prisma (Testcontainers - Postgres)
         run: |
           pnpm -F adapter-prisma prisma:generate
-          pnpm test:prisma-postgres
+          pnpm test:prisma
         env:
           # Ensure Docker is available for Testcontainers
           TESTCONTAINERS_RYUK_DISABLED: true

examples/prisma-client-js/prisma/schema.prisma

@@ -26,6 +26,7 @@ model QueueJob {
   error        Json?     @db.JsonB
   result       Json?     @db.JsonB
   progress     Int?      @default(0)
+  timeout      Json?     @db.JsonB
   cron         String?   @db.VarChar(255)
   repeatEvery  Int?      @map("repeat_every")
   repeatLimit  Int?      @map("repeat_limit")

examples/prisma-client/prisma/schema.prisma

@@ -33,6 +33,7 @@ model QueueJob {
   error        Json?     @db.JsonB
   result       Json?     @db.JsonB
   progress     Int?      @default(0)
+  timeout      Json?     @db.JsonB
   cron         String?   @db.VarChar(255)
   repeatEvery  Int?      @map("repeat_every")
   repeatLimit  Int?      @map("repeat_limit")

package.json

@@ -32,8 +32,8 @@
     "test": "vitest",
     "test:ui": "vitest --ui",
     "test:core": "pnpm -F core test",
-    "test:drizzle-postgres": "pnpm -F adapter-drizzle test:postgres",
-    "test:prisma-postgres": "pnpm -F adapter-prisma test:postgres",
+    "test:drizzle": "pnpm -F adapter-drizzle test",
+    "test:prisma": "pnpm -F adapter-prisma test",
     "cs": "changeset",
     "ci:publish": "pnpm -F adapter-prisma prisma:generate && pnpm build:pkg && pnpm publish -r --access public --publish-branch main && pnpm changeset tag",
     "ci:version": "pnpm changeset version && pnpm install --no-frozen-lockfile && git add ."

packages/adapter-drizzle/package.json

@@ -58,7 +58,6 @@
     "format": "prettier --check . --ignore-path ../../.gitignore",
     "lint": "eslint .",
     "test": "vitest",
-    "test:postgres": "vitest --run tests/drizzle-adapter.test.ts tests/utc-storage.test.ts tests/timezone-edge-cases.test.ts tests/progress.test.ts",
     "test:watch": "vitest --watch",
     "typecheck": "tsc --noEmit"
   },

packages/adapter-drizzle/src/postgres-adapter.ts

@@ -65,6 +65,7 @@ export class PostgresQueueAdapter extends BaseQueueAdapter {
         repeatEvery: job.repeatEvery,
         repeatLimit: job.repeatLimit,
         repeatCount: job.repeatCount,
+        timeout: job.timeout,
       })
       .returning()
 
@@ -254,6 +255,7 @@ export class PostgresQueueAdapter extends BaseQueueAdapter {
       repeatEvery: job.repeatEvery ?? undefined,
       repeatLimit: job.repeatLimit ?? undefined,
       repeatCount: job.repeatCount ?? 0,
+      timeout: job.timeout as number | false | undefined,
     }
   }
 }

packages/adapter-drizzle/src/postgres-schema.ts

@@ -28,6 +28,7 @@ export const queueJobs = pgTable(
     repeatEvery: integer("repeat_every"),
     repeatLimit: integer("repeat_limit"),
     repeatCount: integer("repeat_count").default(0),
+    timeout: jsonb("timeout"),
   },
   (table) => [
     index("idx_queue_jobs_status_priority").on(

packages/adapter-prisma/package.json

@@ -48,7 +48,7 @@
     "format": "prettier --check . --ignore-path ../../.gitignore",
     "lint": "eslint .",
     "prisma:generate": "prisma generate --schema=prisma/schema.prisma",
-    "test:postgres": "vitest",
+    "test": "vitest",
     "typecheck": "tsc --noEmit"
   },
   "prettier": "@vorsteh-queue/prettier-config",

packages/adapter-prisma/prisma/schema.prisma

@@ -31,6 +31,7 @@ model QueueJob {
   error        Json?     @db.JsonB
   result       Json?     @db.JsonB
   progress     Int?      @default(0)
+  timeout      Json?     @db.JsonB
   cron         String?   @db.VarChar(255)
   repeatEvery  Int?      @map("repeat_every")
   repeatLimit  Int?      @map("repeat_limit")