From 9409d5e2664d8d99809956576cee0a0658d54dc7 Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Mon, 27 Feb 2023 09:22:33 +0100 Subject: [PATCH] update --- backend/windmill-worker/src/worker.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs index c2467509ee..525c3e26c1 100644 --- a/backend/windmill-worker/src/worker.rs +++ b/backend/windmill-worker/src/worker.rs @@ -595,11 +595,11 @@ pub async fn run_worker( .await .map_err(|_| Error::InternalErr("Impossible to fetch same_worker job".to_string()))) }, - (job, timer) = { + (job, timer, instant) = { let timer = worker_pull_duration.start_timer(); - let instant = Instant::now(); - pull(&db, WHITELIST_WORKSPACES.clone(), BLACKLIST_WORKSPACES.clone()).map(|x| (x, timer))` } => { - worker_pull_duration_counter.inc_by((elapsed.as_millis() as i64).try_into().unwrap()); + let instant = Instant::now().to_owned(); + pull(&db, WHITELIST_WORKSPACES.clone(), BLACKLIST_WORKSPACES.clone()).map(|x| (x, timer, instant)) } => { + worker_pull_duration_counter.inc_by((instant.elapsed().as_millis() as i64).try_into().unwrap()); drop(timer); (false, job) },