diff --git a/packages/twenty-server/src/engine/metadata-modules/workspace-metadata-cache/services/workspace-metadata-cache.service.ts b/packages/twenty-server/src/engine/metadata-modules/workspace-metadata-cache/services/workspace-metadata-cache.service.ts index 33cccca37..5ae6f7676 100644 --- a/packages/twenty-server/src/engine/metadata-modules/workspace-metadata-cache/services/workspace-metadata-cache.service.ts +++ b/packages/twenty-server/src/engine/metadata-modules/workspace-metadata-cache/services/workspace-metadata-cache.service.ts @@ -55,7 +55,10 @@ export class WorkspaceMetadataCacheService { } if (currentCacheVersion !== undefined) { - this.workspaceCacheStorageService.flush(workspaceId, currentCacheVersion); + this.workspaceCacheStorageService.flushVersionedMetadata( + workspaceId, + currentCacheVersion, + ); } await this.workspaceCacheStorageService.addObjectMetadataCollectionOngoingCachingLock( diff --git a/packages/twenty-server/src/engine/workspace-cache-storage/workspace-cache-storage.service.ts b/packages/twenty-server/src/engine/workspace-cache-storage/workspace-cache-storage.service.ts index 74d33e148..e996c1ab3 100644 --- a/packages/twenty-server/src/engine/workspace-cache-storage/workspace-cache-storage.service.ts +++ b/packages/twenty-server/src/engine/workspace-cache-storage/workspace-cache-storage.service.ts @@ -253,7 +253,10 @@ export class WorkspaceCacheStorageService { ); } - async flush(workspaceId: string, metadataVersion: number): Promise { + async flushVersionedMetadata( + workspaceId: string, + metadataVersion: number, + ): Promise { await this.cacheStorageService.del( `${WorkspaceCacheKeys.MetadataObjectMetadataMaps}:${workspaceId}:${metadataVersion}`, ); @@ -272,6 +275,10 @@ export class WorkspaceCacheStorageService { await this.cacheStorageService.del( `${WorkspaceCacheKeys.MetadataObjectMetadataOngoingCachingLock}:${workspaceId}:${metadataVersion}`, ); + } + + async flush(workspaceId: string, metadataVersion: number): Promise { + await this.flushVersionedMetadata(workspaceId, metadataVersion); await this.cacheStorageService.del( `${WorkspaceCacheKeys.MetadataPermissionsRolesPermissions}:${workspaceId}`,