diff --git a/packages/twenty-server/src/engine/core-modules/cache-storage/services/cache-storage.service.ts b/packages/twenty-server/src/engine/core-modules/cache-storage/services/cache-storage.service.ts index 23519d9102..65d96afbee 100644 --- a/packages/twenty-server/src/engine/core-modules/cache-storage/services/cache-storage.service.ts +++ b/packages/twenty-server/src/engine/core-modules/cache-storage/services/cache-storage.service.ts @@ -67,20 +67,7 @@ export class CacheStorageService { async mset( entries: Array<{ key: string; value: T; ttl?: Milliseconds }>, ): Promise { - if (this.isRedisCache()) { - const pipeline = (this.cache as RedisCache).store.client.multi(); - - entries.forEach(({ key, value, ttl }) => { - const prefixedKey = this.getKey(key); - - pipeline.set(prefixedKey, JSON.stringify(value)); - if (ttl) { - pipeline.expire(prefixedKey, Math.floor(ttl / 1000)); - } - }); - - await pipeline.exec(); - + if (entries.length === 0) { return; }