Add configurable user-visible log message for memory errors

francesconazzaro · francesconazzaro · commit a8cd3d6c2418 · 2025-02-03T10:46:58.000+01:00
diff --git a/cads_broker/config.py b/cads_broker/config.py
@@ -42,6 +42,7 @@ class BrokerConfig(pydantic_settings.BaseSettings):
     broker_max_dismissed_requests: int = 100
     broker_cancel_stuck_requests_cache_ttl: int = 60
     broker_stuck_requests_limit_minutes: int = 15
+    broker_memory_error_user_visible_log: str = "Worker has been killed due to memory usage."
 
 
 class SqlalchemySettings(pydantic_settings.BaseSettings):
diff --git a/cads_broker/dispatcher.py b/cads_broker/dispatcher.py
@@ -378,7 +378,7 @@ def set_request_error_status(
                         db.add_event(
                             event_type="user_visible_error",
                             request_uid=request_uid,
-                            message="Worker has been killed due to memory usage. ",
+                            message=CONFIG.broker_memory_error_user_visible_log,
                             session=session,
                         )
                         request = db.set_request_status(

Original file line number	Diff line number	Diff line change
`@@ -378,7 +378,7 @@ def set_request_error_status(`
`378`	`378`	`db.add_event(`
`379`	`379`	`event_type="user_visible_error",`
`380`	`380`	`request_uid=request_uid,`
`381`		`- message="Worker has been killed due to memory usage. ",`
	`381`	`+ message=CONFIG.broker_memory_error_user_visible_log,`
`382`	`382`	`session=session,`
`383`	`383`	`)`
`384`	`384`	`request = db.set_request_status(`