diff --git a/apps/schedules/src/queue.ts b/apps/schedules/src/queue.ts index 956e963dc..6930c6f66 100644 --- a/apps/schedules/src/queue.ts +++ b/apps/schedules/src/queue.ts @@ -3,11 +3,9 @@ import { logger } from "./logger"; import type { QueueJob } from "./schema"; import IORedis from "ioredis"; -export const connection = new IORedis({ +export const connection = new IORedis(process.env.REDIS_URL || "", { maxRetriesPerRequest: null, - path: process.env.REDIS_URL, }); - export const jobQueue = new Queue("backupQueue", { connection, defaultJobOptions: { diff --git a/apps/schedules/src/workers.ts b/apps/schedules/src/workers.ts index 646c1072c..7711891e3 100644 --- a/apps/schedules/src/workers.ts +++ b/apps/schedules/src/workers.ts @@ -1,7 +1,6 @@ import { type Job, Worker } from "bullmq"; import type { QueueJob } from "./schema"; import { runJobs } from "./utils"; -import Redis from "ioredis"; import { connection } from "./queue"; export const firstWorker = new Worker(