diff --git a/src/common/redis/index.ts b/src/common/redis/index.ts index abb4f97..83a5672 100644 --- a/src/common/redis/index.ts +++ b/src/common/redis/index.ts @@ -14,9 +14,9 @@ const createConnectionOptions = (redisConfig: RedisConfig): Partial(SERVICES.LOGGER); try { const redis = deps.resolve(SERVICES.REDIS); + + await redis.connect(); + cleanupRegistry.register({ - func: async (): Promise => { - await redis.quit(); - return Promise.resolve(); - }, id: SERVICES.REDIS, + func: redis.quit.bind(redis), }); - await redis.connect(); } catch (error) { logger.error({ msg: 'Connection to redis failed', error }); + throw error; } }, },