From 24e4930fc11c84199ac2c0f733866e05618ae70b Mon Sep 17 00:00:00 2001 From: Mauricio Siu <47042324+Siumauricio@users.noreply.github.com> Date: Sun, 6 Oct 2024 02:57:46 -0600 Subject: [PATCH] refactor: use connection IORedis --- apps/schedules/src/queue.ts | 4 +--- apps/schedules/src/workers.ts | 1 - 2 files changed, 1 insertion(+), 4 deletions(-) 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(