From c7cec29c8399cdef9fd783631cc63fd6a3e34b33 Mon Sep 17 00:00:00 2001
From: maaz519 <maaz@insigniaconsultancy.com>
Date: Wed, 27 May 2026 16:23:55 +0530
Subject: [PATCH] fix: rename queue from tower:ingest to tower-ingest (BullMQ
 v5 forbids colons)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
---
 apps/worker/src/queues/ingest.processor.ts | 2 +-
 apps/worker/src/queues/ingest.queue.ts     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/worker/src/queues/ingest.processor.ts b/apps/worker/src/queues/ingest.processor.ts
index 9904607..26cb1b2 100644
--- a/apps/worker/src/queues/ingest.processor.ts
+++ b/apps/worker/src/queues/ingest.processor.ts
@@ -26,7 +26,7 @@ export async function processIngestJob(job: IngestJobData, prisma: any): Promise
 
 export function createIngestWorker(redisUrl: string, prisma: any): Worker<IngestJobData> {
   return new Worker<IngestJobData>(
-    'tower:ingest',
+    'tower-ingest',
     async (job) => processIngestJob(job.data, prisma),
     { connection: parseRedisUrl(redisUrl) },
   );
diff --git a/apps/worker/src/queues/ingest.queue.ts b/apps/worker/src/queues/ingest.queue.ts
index e6d7a13..f187623 100644
--- a/apps/worker/src/queues/ingest.queue.ts
+++ b/apps/worker/src/queues/ingest.queue.ts
@@ -3,5 +3,5 @@ import { IngestJobData } from '@tower/types';
 import { parseRedisUrl } from './redis-connection';
 
 export function createIngestQueue(redisUrl: string): Queue<IngestJobData> {
-  return new Queue<IngestJobData>('tower:ingest', { connection: parseRedisUrl(redisUrl) });
+  return new Queue<IngestJobData>('tower-ingest', { connection: parseRedisUrl(redisUrl) });
 }