diff --git a/src/utils/redis.ts b/src/utils/redis.ts index 68240ea..3997465 100644 --- a/src/utils/redis.ts +++ b/src/utils/redis.ts @@ -53,7 +53,7 @@ if (config.redis?.enabled) { const get = client.get.bind(client); const getRead = readClient?.get?.bind(readClient); exportClient.get = (key) => new Promise((resolve, reject) => { - if (activeRequests > config.redis.maxConnections) { + if (config.redis.maxConnections && activeRequests > config.redis.maxConnections) { reject("Too many active requests"); return; } @@ -85,7 +85,7 @@ if (config.redis?.enabled) { const setFun = >(func: (...args: T) => Promise , params: T): Promise => new Promise((resolve, reject) => { - if (activeRequests > config.redis.maxWriteConnections) { + if (config.redis.maxWriteConnections && activeRequests > config.redis.maxWriteConnections) { reject("Too many active requests"); return; }