Merge pull request #188 from ecmwf-projects/fix-cache-race-condition

Fix cache race condition

Author: mcucchi9

cads_processing_api_service/auth.py

@@ -78,7 +78,6 @@ def get_auth_header(
         maxsize=config.ensure_settings().cache_users_maxsize,
         ttl=config.ensure_settings().cache_users_ttl,
     ),
-    info=True,
 )
 def authenticate_user(
     auth_header: tuple[str, str], portal_header: str | None = None
@@ -156,7 +155,6 @@ def verify_permission(user_uid: str, job: cads_broker.SystemRequest) -> None:
         maxsize=config.ensure_settings().cache_users_maxsize,
         ttl=config.ensure_settings().cache_users_ttl,
     ),
-    info=True,
 )
 def get_accepted_licences(auth_header: tuple[str, str]) -> set[tuple[str, int]]:
     """Get licences accepted by a user stored in the Extended Profiles database.

cads_processing_api_service/utils.py

@@ -17,6 +17,7 @@
 import base64
 import datetime
 import enum
+import threading
 from typing import Any, Callable, Mapping
 
 import cachetools
@@ -54,6 +55,7 @@ class JobSortCriterion(str, enum.Enum):
         maxsize=config.ensure_settings().cache_resources_maxsize,
         ttl=config.ensure_settings().cache_resources_ttl,
     ),
+    lock=threading.Lock(),
     key=lambda resource_id,
     table,
     session,