diff --git a/src/database/redis/connection.js b/src/database/redis/connection.js index 41a9243355..b97f75a4a4 100644 --- a/src/database/redis/connection.js +++ b/src/database/redis/connection.js @@ -58,13 +58,12 @@ connection.connect = async function (options) { winston.error(err.stack); reject(err); }); - cxn.on('ready', () => { + + cxn.connect().then(() => { // back-compat with node_redis cxn.batch = cxn.multi; - resolve(cxn); - }); - cxn.connect().then(() => { winston.info('Connected to Redis successfully'); + resolve(cxn); }).catch((err) => { winston.error('Error connecting to Redis:', err); });