improve log messages

francesconazzaro · francesconazzaro · commit 248004d3b1b6 · 2025-01-16T16:54:02.000+01:00
diff --git a/cads_broker/dispatcher.py b/cads_broker/dispatcher.py
@@ -109,11 +109,11 @@ def kill_job_on_worker(client: distributed.Client, request_uid: str) -> None:
                 nanny=True,
             )
             logger.info(
-                "killing worker", job_id=request_uid, pid=pid, worker_ip=worker_ip
+                "killed job on worker", job_id=request_uid, pid=pid, worker_ip=worker_ip
             )
         except (KeyError, NameError):
             logger.warning(
-                "worker not found", job_id=request_uid, pid=pid, worker_ip=worker_ip
+                "worker not found while killing a job", job_id=request_uid, pid=pid, worker_ip=worker_ip
             )
 
 

Original file line number	Diff line number	Diff line change
`@@ -109,11 +109,11 @@ def kill_job_on_worker(client: distributed.Client, request_uid: str) -> None:`
`109`	`109`	`nanny=True,`
`110`	`110`	`)`
`111`	`111`	`logger.info(`
`112`		`- "killing worker", job_id=request_uid, pid=pid, worker_ip=worker_ip`
	`112`	`+ "killed job on worker", job_id=request_uid, pid=pid, worker_ip=worker_ip`
`113`	`113`	`)`
`114`	`114`	`except (KeyError, NameError):`
`115`	`115`	`logger.warning(`
`116`		`- "worker not found", job_id=request_uid, pid=pid, worker_ip=worker_ip`
	`116`	`+ "worker not found while killing a job", job_id=request_uid, pid=pid, worker_ip=worker_ip`
`117`	`117`	`)`
`118`	`118`
`119`	`119`