diff --git a/core/node/da_dispatcher/src/da_dispatcher.rs b/core/node/da_dispatcher/src/da_dispatcher.rs index 2f46419f7972..10a895df4956 100644 --- a/core/node/da_dispatcher/src/da_dispatcher.rs +++ b/core/node/da_dispatcher/src/da_dispatcher.rs @@ -83,7 +83,6 @@ impl DataAvailabilityDispatcher { for batch in batches { let dispatch_latency = METRICS.blob_dispatch_latency.start(); - METRICS.blobs_pending_dispatch.inc_by(1); let dispatch_response = retry(self.config.max_retries(), batch.l1_batch_number, || { self.client .dispatch_blob(batch.l1_batch_number.0, batch.pubdata.clone()) @@ -115,7 +114,6 @@ impl DataAvailabilityDispatcher { .set(batch.l1_batch_number.0 as usize); METRICS.blob_size.observe(batch.pubdata.len()); METRICS.blobs_dispatched.inc_by(1); - METRICS.blobs_pending_dispatch.dec_by(1); tracing::info!( "Dispatched a DA for batch_number: {}, pubdata_size: {}, dispatch_latency: {dispatch_latency_duration:?}", diff --git a/core/node/da_dispatcher/src/metrics.rs b/core/node/da_dispatcher/src/metrics.rs index 4c21e556abe1..2f469c865b6c 100644 --- a/core/node/da_dispatcher/src/metrics.rs +++ b/core/node/da_dispatcher/src/metrics.rs @@ -19,8 +19,6 @@ pub(super) struct DataAvailabilityDispatcherMetrics { /// Buckets are bytes ranging from 1 KB to 16 MB, which has to satisfy all blob size values. #[metrics(buckets = Buckets::exponential(1_024.0..=16.0 * 1_024.0 * 1_024.0, 2.0), unit = Unit::Bytes)] pub blob_size: Histogram, - /// Amount of pending blobs to be dispatched. - pub blobs_pending_dispatch: Gauge, /// Total number of blobs dispatched. pub blobs_dispatched: Gauge, /// Total number of blobs included.