From 99cb497578699e90b751dc40c48f8be3f4cc45f5 Mon Sep 17 00:00:00 2001
From: dapplion <35266934+dapplion@users.noreply.github.com>
Date: Wed, 22 Feb 2023 17:37:51 +0800
Subject: [PATCH] Track gossipValidationQueueConcurrency

---
 packages/beacon-node/src/metrics/metrics/lodestar.ts | 2 +-
 packages/beacon-node/src/network/processor/index.ts  | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

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]);
         }
       });
     }