diff --git a/cads_processing_api_service/clients.py b/cads_processing_api_service/clients.py index d7b0836d..35bcb267 100644 --- 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,