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

add more metrics

Browse Source
This commit is contained in:
Ruben Fiszel
2022-12-12 23:10:53 +01:00
parent a8c098736b
commit a02aff76be
1 changed files with 21 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker.rs
+21 -2
View File
@@ -372,6 +372,20 @@ pub async fn run_worker(
)
.expect("register prometheus metric");
let worker_sleep_duration = prometheus::register_histogram!(prometheus::HistogramOpts::new(
"worker_sleep_duration",
"Duration sleeping waiting for job",
)
.const_label("name", &worker_name),)
.expect("register prometheus metric");
let worker_pull_duration = prometheus::register_histogram!(prometheus::HistogramOpts::new(
"worker_pull_duration",
"Duration pulling next job",
)
.const_label("name", &worker_name),)
.expect("register prometheus metric");
let worker_execution_failed = prometheus::register_int_counter_vec!(
prometheus::Opts::new("worker_execution_failed", "Number of failed jobs",)
.const_label("name", &worker_name),
@@ -479,7 +493,7 @@ pub async fn run_worker(
.await
.map_err(|_| Error::InternalErr("Impossible to fetch same_worker job".to_string())))
},
job = pull(&db) => (false, job),
job = { let _timer = worker_pull_duration.start_timer(); pull(&db) } => (false, job),
}
}.instrument(trace_span!("worker_get_next_job")).await;
if do_break {
@@ -592,7 +606,12 @@ pub async fn run_worker(
}
}
Ok(None) => {
tokio::time::sleep(Duration::from_millis(sleep_queue * num_workers)).await
let _timer = worker_sleep_duration
.start_timer();
tokio::time::sleep(Duration::from_millis(sleep_queue * num_workers)).await;
}
Err(err) => {
tracing::error!(worker = %worker_name, "run_worker: pulling jobs: {}", err);