refactor: use connection IORedis

This commit is contained in:
Mauricio Siu 2024-10-06 02:57:46 -06:00
parent 541728805f
commit 24e4930fc1
2 changed files with 1 additions and 4 deletions

View File

@ -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: {

View File

@ -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(