diff --git a/packages/beacon-node/src/metrics/metrics/lodestar.ts b/packages/beacon-node/src/metrics/metrics/lodestar.ts index fac020d9fcff..f857c6fc7710 100644 --- a/packages/beacon-node/src/metrics/metrics/lodestar.ts +++ b/packages/beacon-node/src/metrics/metrics/lodestar.ts @@ -267,7 +267,7 @@ export function createLodestarMetrics( }), gossipValidationQueueConcurrency: register.gauge<"topic">({ name: "lodestar_gossip_validation_queue_concurrency", - help: "Current concurrency of gossip validation queue", + help: "Current count of jobs being run on network processor for topic", labelNames: ["topic"], }), diff --git a/packages/beacon-node/src/network/processor/index.ts b/packages/beacon-node/src/network/processor/index.ts index d7ac3aa06ef8..241e7ad70d0e 100644 --- a/packages/beacon-node/src/network/processor/index.ts +++ b/packages/beacon-node/src/network/processor/index.ts @@ -76,6 +76,7 @@ export class NetworkProcessor { metrics.gossipValidationQueueLength.addCollect(() => { for (const topic of executeGossipWorkOrder) { metrics.gossipValidationQueueLength.set({topic}, this.gossipQueues[topic].length); + metrics.gossipValidationQueueConcurrency.set({topic}, this.gossipTopicConcurrency[topic]); } }); }