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 { 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 { async add(data: T, opts?: JobOptions): Promise> { 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 { 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) )