diff --git a/src/server/jobs/queues.ts b/src/server/jobs/queues.ts index 231859b..315d0b2 100644 --- a/src/server/jobs/queues.ts +++ b/src/server/jobs/queues.ts @@ -75,7 +75,8 @@ function queue(name: JobQueueName): Queue | null { export async function enqueueJob(name: JobQueueName, payload: JobPayload): Promise { const q = queue(name); if (!q) return false; - await q.add(name, payload, { jobId: `${name}:${payload.tenantId}:${payload.entityId}:${Date.now()}` }); + // BullMQ rejects custom job ids containing ":" (reserved for its Redis key layout). + await q.add(name, payload, { jobId: `${name}__${payload.tenantId}__${payload.entityId}__${Date.now()}` }); return true; }