Merge pull request #243 from ecmwf-projects/add-user-uid-to-logs

Add user uid to logs

Author: mcucchi9

cads_processing_api_service/clients.py

@@ -225,6 +225,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,
@@ -375,6 +376,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,
@@ -490,6 +492,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,
@@ -605,6 +608,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,
@@ -667,6 +671,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,