From 1b3b215bff17f206bd786f5f9928b9d22e5d357f Mon Sep 17 00:00:00 2001
From: Ruslan Bakiev <572431+veikab@users.noreply.github.com>
Date: Mon, 23 Feb 2026 09:10:06 +0700
Subject: [PATCH] fix(queue): use BullMQ-safe outbound job ids

---
 frontend/server/queues/outboundDelivery.ts   | 2 +-
 omni_outbound/src/queues/outboundDelivery.ts | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/frontend/server/queues/outboundDelivery.ts b/frontend/server/queues/outboundDelivery.ts
index 57cb2a3..c7d62a4 100644
--- a/frontend/server/queues/outboundDelivery.ts
+++ b/frontend/server/queues/outboundDelivery.ts
@@ -99,7 +99,7 @@ export async function enqueueOutboundDelivery(input: OutboundDeliveryJob, opts?:
   });
 
   return q.add("deliver", { ...input, endpoint }, {
-    jobId: `omni:${input.omniMessageId}`,
+    jobId: `omni-${input.omniMessageId}`,
     attempts: 12,
     backoff: { type: "exponential", delay: 1000 },
     ...opts,
diff --git a/omni_outbound/src/queues/outboundDelivery.ts b/omni_outbound/src/queues/outboundDelivery.ts
index 70014b3..229be49 100644
--- a/omni_outbound/src/queues/outboundDelivery.ts
+++ b/omni_outbound/src/queues/outboundDelivery.ts
@@ -98,7 +98,7 @@ export async function enqueueOutboundDelivery(input: OutboundDeliveryJob, opts?:
   });
 
   return q.add("deliver", { ...input, endpoint }, {
-    jobId: `omni:${input.omniMessageId}`,
+    jobId: `omni-${input.omniMessageId}`,
     attempts: 12,
     backoff: { type: "exponential", delay: 1000 },
     ...opts,