fix(redis): redis connection not opened

restorecommerce · May 13, 2024 · 853e2e6 · 853e2e6
1 parent 3ab8444
commit 853e2e6
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/worker.ts b/src/worker.ts
@@ -182,9 +182,11 @@ export class Worker {
     this.events = new Events(kafkaCfg, logger);
     await this.events.start();
     this.offsetStore = new OffsetStore(this.events, cfg, logger);
+
     const redisConfig = cfg.get('redis');
     redisConfig.db = this.cfg.get('redis:db-indexes:db-subject');
     this.redisClient = createClient(redisConfig);
+    await this.redisClient.connect();
 
     await Promise.all(Object.keys(kafkaCfg.topics).map(async key => {
       const topicName = kafkaCfg.topics[key].topic;