1
0
Fork 0
mirror of synced 2024-10-04 03:54:37 +13:00

Updating redis option functions usage, as it is no longer returned as a part of the getRedisOptions response.

This commit is contained in:
mike12345567 2023-11-03 18:06:12 +00:00
parent 7bf307b0c2
commit 08c4ba0097
2 changed files with 4 additions and 2 deletions

View file

@ -26,7 +26,7 @@ export function createQueue<T>(
jobQueue: JobQueue,
opts: { removeStalledCb?: StalledFn } = {}
): BullQueue.Queue<T> {
const { opts: redisOpts } = getRedisOptions()
const redisOpts = getRedisOptions()
const queueConfig: QueueOptions = {
redis: redisOpts,
settings: {

View file

@ -16,6 +16,7 @@ import {
getRedisOptions,
SEPARATOR,
SelectableDatabase,
getRedisConnectionDetails,
} from "./utils"
import * as timers from "../timers"
@ -91,7 +92,8 @@ function init(selectDb = DEFAULT_SELECT_DB) {
if (client) {
client.disconnect()
}
const { opts, host, port } = getRedisOptions()
const { host, port } = getRedisConnectionDetails()
const opts = getRedisOptions()
if (CLUSTERED) {
client = new RedisCore.Cluster([{ host, port }], opts)