fix: Add Cache Version Keys

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:

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:

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:

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: