maaz519/tower
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: rename queue from tower:ingest to tower-ingest (BullMQ v5 forbids colons)

Browse Source 
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Maaz Ahamed
2026-05-27 16:23:55 +05:30
parent b32f901005
commit c7cec29c83
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/worker/src/queues/ingest.processor.ts
+1 -1
View File
@@ -26,7 +26,7 @@ export async function processIngestJob(job: IngestJobData, prisma: any): Promise
export function createIngestWorker(redisUrl: string, prisma: any): Worker<IngestJobData> { export function createIngestWorker(redisUrl: string, prisma: any): Worker<IngestJobData> {
return new Worker<IngestJobData>( return new Worker<IngestJobData>(
'tower:ingest', 'tower-ingest',
async (job) => processIngestJob(job.data, prisma), async (job) => processIngestJob(job.data, prisma),
{ connection: parseRedisUrl(redisUrl) }, { connection: parseRedisUrl(redisUrl) },
); );
apps/worker/src/queues/ingest.queue.ts
+1 -1
View File
@@ -3,5 +3,5 @@ import { IngestJobData } from '@tower/types';
import { parseRedisUrl } from './redis-connection'; import { parseRedisUrl } from './redis-connection';
export function createIngestQueue(redisUrl: string): Queue<IngestJobData> { 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) });
} }