bind user_uid to logs

ecmwf-projects · Feb 11, 2025 · e633ae0 · e633ae0
1 parent 9e8d73b
commit e633ae0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cads_processing_api_service/clients.py b/cads_processing_api_service/clients.py
@@ -216,6 +216,7 @@ def post_process_execution(
         models.StatusInfo
             Submitted job's status information.
         """
+        structlog.contextvars.bind_contextvars(user_uid=auth_info.user_uid)
         _ = limits.check_rate_limits(
             SETTINGS.rate_limits.process_execution.post,
             auth_info,
@@ -371,6 +372,7 @@ def get_jobs(
         models.JobList
             List of jobs status information.
         """
+        structlog.contextvars.bind_contextvars(user_uid=auth_info.user_uid)
         _ = limits.check_rate_limits(
             SETTINGS.rate_limits.jobs.get,
             auth_info,
@@ -491,6 +493,7 @@ def get_job(
         models.StatusInfo
             Job status information.
         """
+        structlog.contextvars.bind_contextvars(user_uid=auth_info.user_uid)
         _ = limits.check_rate_limits(
             SETTINGS.rate_limits.job.get,
             auth_info,
@@ -611,6 +614,7 @@ def get_job_results(
         ogc_api_processes_fastapi.models.Results
             Job results.
         """
+        structlog.contextvars.bind_contextvars(user_uid=auth_info.user_uid)
         _ = limits.check_rate_limits(
             SETTINGS.rate_limits.job_results.get,
             auth_info,
@@ -673,6 +677,7 @@ def delete_job(
         ogc_api_processes_fastapi.models.StatusInfo
             Job status information
         """
+        structlog.contextvars.bind_contextvars(user_uid=auth_info.user_uid)
         _ = limits.check_rate_limits(
             SETTINGS.rate_limits.job.delete,
             auth_info,