From 08de2b1d22f671666bd387f78a6187eb70f7941e Mon Sep 17 00:00:00 2001
From: Vineeth Voruganti <13438633+VVoruganti@users.noreply.github.com>
Date: Mon, 23 Feb 2026 15:45:39 -0500
Subject: [PATCH] fix: Add Cache Version Keys

---
 src/crud/collection.py | 4 ++--
 src/crud/peer.py       | 4 ++--
 src/crud/session.py    | 4 ++--
 src/crud/workspace.py  | 4 ++--
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/crud/collection.py b/src/crud/collection.py
index e5ced71d..f0496d50 100644
--- a/src/crud/collection.py
+++ b/src/crud/collection.py
@@ -20,9 +20,9 @@ from src.exceptions import ConflictException, ResourceNotFoundException
 logger = getLogger(__name__)
 
 COLLECTION_CACHE_KEY_TEMPLATE = (
-    "workspace:{workspace_name}:collection:{observer}:{observed}"
+    "v2:workspace:{workspace_name}:collection:{observer}:{observed}"
 )
-COLLECTION_LOCK_PREFIX = f"{get_cache_namespace()}:lock"
+COLLECTION_LOCK_PREFIX = f"{get_cache_namespace()}:lock:v2"
 
 
 def collection_cache_key(workspace_name: str, observer: str, observed: str) -> str:
diff --git a/src/crud/peer.py b/src/crud/peer.py
index 22c33603..7af73e9e 100644
--- a/src/crud/peer.py
+++ b/src/crud/peer.py
@@ -18,8 +18,8 @@ from src.utils.types import GetOrCreateResult
 
 logger = getLogger(__name__)
 
-PEER_CACHE_KEY_TEMPLATE = "workspace:{workspace_name}:peer:{peer_name}"
-PEER_LOCK_PREFIX = f"{get_cache_namespace()}:lock"
+PEER_CACHE_KEY_TEMPLATE = "v2:workspace:{workspace_name}:peer:{peer_name}"
+PEER_LOCK_PREFIX = f"{get_cache_namespace()}:lock:v2"
 
 
 def peer_cache_key(workspace_name: str, peer_name: str) -> str:
diff --git a/src/crud/session.py b/src/crud/session.py
index 2d0f857c..d061f0bb 100644
--- a/src/crud/session.py
+++ b/src/crud/session.py
@@ -42,8 +42,8 @@ class SessionDeletionResult:
     conclusions_deleted: int
 
 
-SESSION_CACHE_KEY_TEMPLATE = "workspace:{workspace_name}:session:{session_name}"
-SESSION_LOCK_PREFIX = f"{get_cache_namespace()}:lock"
+SESSION_CACHE_KEY_TEMPLATE = "v2:workspace:{workspace_name}:session:{session_name}"
+SESSION_LOCK_PREFIX = f"{get_cache_namespace()}:lock:v2"
 
 
 def session_cache_key(workspace_name: str, session_name: str) -> str:
diff --git a/src/crud/workspace.py b/src/crud/workspace.py
index c6a10500..b77223c0 100644
--- a/src/crud/workspace.py
+++ b/src/crud/workspace.py
@@ -35,8 +35,8 @@ class WorkspaceDeletionResult:
     conclusions_deleted: int
 
 
-WORKSPACE_CACHE_KEY_TEMPLATE = "workspace:{workspace_name}"
-WORKSPACE_LOCK_PREFIX = f"{get_cache_namespace()}:lock"
+WORKSPACE_CACHE_KEY_TEMPLATE = "v2:workspace:{workspace_name}"
+WORKSPACE_LOCK_PREFIX = f"{get_cache_namespace()}:lock:v2"
 
 
 def workspace_cache_key(workspace_name: str) -> str: