starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-09-06 08:01:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
Ruben Fiszel
2023-02-27 10:41:23 +01:00
parent 2d71ebbe09
commit 9409d5e266
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker.rs
+4 -4
View File
@@ -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)
},