From 46bc81b4c82bb47626b1155b8db543a4850ae833 Mon Sep 17 00:00:00 2001 From: terence Date: Thu, 23 Oct 2025 08:50:25 -0700 Subject: [PATCH] Add metric to track data columns recovered from execution layer (#15924) --- beacon-chain/sync/metrics.go | 7 +++++++ beacon-chain/sync/subscriber_beacon_blocks.go | 2 ++ changelog/ttsao_add-columns-recovery-metric.md | 3 +++ 3 files changed, 12 insertions(+) create mode 100644 changelog/ttsao_add-columns-recovery-metric.md diff --git a/beacon-chain/sync/metrics.go b/beacon-chain/sync/metrics.go index 64b4c2bb9d..8e107273d6 100644 --- a/beacon-chain/sync/metrics.go +++ b/beacon-chain/sync/metrics.go @@ -192,6 +192,13 @@ var ( }, ) + dataColumnsRecoveredFromELTotal = promauto.NewCounter( + prometheus.CounterOpts{ + Name: "data_columns_recovered_from_el_total", + Help: "Count the number of times data columns have been recovered from the execution layer.", + }, + ) + // Data column sidecar validation, beacon metrics specs dataColumnSidecarVerificationRequestsCounter = promauto.NewCounter(prometheus.CounterOpts{ Name: "beacon_data_column_sidecar_processing_requests_total", diff --git a/beacon-chain/sync/subscriber_beacon_blocks.go b/beacon-chain/sync/subscriber_beacon_blocks.go index 8278f67ed7..92017f56b6 100644 --- a/beacon-chain/sync/subscriber_beacon_blocks.go +++ b/beacon-chain/sync/subscriber_beacon_blocks.go @@ -224,6 +224,8 @@ func (s *Service) processDataColumnSidecarsFromExecution(ctx context.Context, so } if len(unseenIndices) > 0 { + dataColumnsRecoveredFromELTotal.Inc() + log.WithFields(logrus.Fields{ "root": fmt.Sprintf("%#x", source.Root()), "slot": source.Slot(), diff --git a/changelog/ttsao_add-columns-recovery-metric.md b/changelog/ttsao_add-columns-recovery-metric.md new file mode 100644 index 0000000000..b4e4212e3a --- /dev/null +++ b/changelog/ttsao_add-columns-recovery-metric.md @@ -0,0 +1,3 @@ +### Added + +- Metric to track data columns recovered from execution layer