From 32e808563ed994a5ce57c871b3f34bc54817f8cb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= <mo.geryy@gmail.com>
Date: Sun, 5 Oct 2025 12:15:04 +0200
Subject: [PATCH] feat(nuq): fix per-message TTL on prefetch

---
 apps/api/src/services/worker/nuq.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/api/src/services/worker/nuq.ts b/apps/api/src/services/worker/nuq.ts
index 2e20925fc..62c679fb4 100644
--- a/apps/api/src/services/worker/nuq.ts
+++ b/apps/api/src/services/worker/nuq.ts
@@ -281,7 +281,7 @@ class NuQ<JobData = any, JobReturnValue = any> {
         {
           correlationId: job.id,
           persistent: true,
-          expiration: "30000",
+          expiration: "15000", // has to expire in 15s otherwise locks will fail to be acquired for jobs that got picked up late
         },
       );
       _logger.info("NuQ job prefetch sent", { module: "nuq/rabbitmq" });