Fix the blob metrics fetch in data api (#40)

Layr-Labs · Nov 16, 2023 · d6ca784 · d6ca784
1 parent 1ef09d5
commit d6ca784
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/disperser/dataapi/metrics_handlers.go b/disperser/dataapi/metrics_handlers.go
@@ -79,7 +79,7 @@ func (s *server) calculateTotalStake(operators []*Operator, blockNumber uint32)
 		pool                     = workerpool.New(maxWorkersGetOperatorState)
 	)
 
-	s.logger.Debug("Number of operators to calculate stake:", len(operators))
+	s.logger.Debug("Number of operators to calculate stake:", "numOperators", len(operators), "blockNumber", blockNumber)
 	for _, o := range operators {
 		operatorId, err := ConvertHexadecimalToBytes(o.OperatorId)
 		if err != nil {

diff --git a/disperser/dataapi/prometheus_client.go b/disperser/dataapi/prometheus_client.go
@@ -39,7 +39,7 @@ func NewPrometheusClient(api prometheus.Api, cluster string) *prometheusClient {
 }
 
 func (pc *prometheusClient) QueryDisperserBlobSizeBytesPerSecond(ctx context.Context, start time.Time, end time.Time) (*PrometheusResult, error) {
-	query := fmt.Sprintf("eigenda_batcher_blobs_total{state=\"completed\",data=\"size\",cluster=\"%s\"}", pc.cluster)
+	query := fmt.Sprintf("eigenda_batcher_blobs_total{state=\"confirmed\",data=\"size\",cluster=\"%s\"}", pc.cluster)
 	numSecondsInTimeRange := end.Sub(start).Seconds()
 	step := uint64(numSecondsInTimeRange / maxNumOfDataPoints)
 	if step < 1 {