diff --git a/hook-worker/src/worker.rs b/hook-worker/src/worker.rs index c526c3f..617a322 100644 --- a/hook-worker/src/worker.rs +++ b/hook-worker/src/worker.rs @@ -2,6 +2,7 @@ use std::collections; use std::sync::Arc; use std::time; +use chrono::Utc; use hook_common::health::HealthHandle; use hook_common::{ pgqueue::{Job, PgJob, PgJobError, PgQueue, PgQueueError, PgQueueJob, PgTransactionJob}, @@ -264,6 +265,10 @@ async fn process_webhook_job( match send_result { Ok(_) => { + let insert_to_complete_duration = Utc::now() - webhook_job.job().created_at; + metrics::histogram!("webhook_jobs_insert_to_complete_duration_seconds", &labels) + .record((insert_to_complete_duration.num_milliseconds() as f64) / 1_000_f64); + webhook_job .complete() .await