From 2f2424d8f58757df2076582ea1427aefe9aad5d2 Mon Sep 17 00:00:00 2001
From: Sam Rose <hello@samwho.dev>
Date: Thu, 27 Mar 2025 11:53:50 +0000
Subject: [PATCH] More stats.

---
 packages/backend-core/src/queue/queue.ts | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/packages/backend-core/src/queue/queue.ts b/packages/backend-core/src/queue/queue.ts
index 2d6af9954e..9a612f3004 100644
--- a/packages/backend-core/src/queue/queue.ts
+++ b/packages/backend-core/src/queue/queue.ts
@@ -173,6 +173,11 @@ export class BudibaseQueue<T> {
           span.addTags(this.opts.jobTags(job.data))
         }
 
+        tracer.dogstatsd.distribution(
+          "queue.process.sizeBytes",
+          sizeof(job.data),
+          this.metricTags()
+        )
         await this.withMetrics("queue.process", () => cb(job))
       })
     }
@@ -186,7 +191,11 @@ export class BudibaseQueue<T> {
 
   async add(data: T, opts?: JobOptions): Promise<Job<T>> {
     return await tracer.trace("queue.add", async span => {
-      span.addTags({ "queue.name": this.jobQueue, ...jobOptsTags(opts || {}) })
+      span.addTags({
+        "queue.name": this.jobQueue,
+        "job.data.sizeBytes": sizeof(data),
+        ...jobOptsTags(opts || {}),
+      })
       if (this.opts.jobTags) {
         span.addTags(this.opts.jobTags(data))
       }
@@ -196,6 +205,11 @@ export class BudibaseQueue<T> {
         spanId: span.context().toSpanId(),
       }
 
+      tracer.dogstatsd.distribution(
+        "queue.add.sizeBytes",
+        sizeof(data),
+        this.metricTags()
+      )
       return await this.withMetrics("queue.add", () =>
         this.queue.add(data, opts)
       )