From d813c007c0b00a18b4e2d85fa4a71d02a7548551 Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Tue, 13 Dec 2022 00:25:27 +0100 Subject: [PATCH] add more metrics --- backend/windmill-worker/src/worker.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs index 7fdde2bc83..bf1e5338ac 100644 --- a/backend/windmill-worker/src/worker.rs +++ b/backend/windmill-worker/src/worker.rs @@ -493,7 +493,10 @@ pub async fn run_worker( .await .map_err(|_| Error::InternalErr("Impossible to fetch same_worker job".to_string()))) }, - job = { let _timer = worker_pull_duration.start_timer(); pull(&db) } => (false, job), + (job, timer) = {let timer = worker_pull_duration.start_timer(); pull(&db).map(|x| (x, timer)) } => { + drop(timer); + (false, job) + }, } }.instrument(trace_span!("worker_get_next_job")).await; if do_break {