Add histogram for insertion time to completion time

PostHog · Feb 6, 2024 · e434877 · e434877
1 parent 304852c
commit e434877
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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<W: WebhookJob>(
 
     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