diff --git a/internal/p2p/pqueue.go b/internal/p2p/pqueue.go index bd1f5754e..b19436e15 100644 --- a/internal/p2p/pqueue.go +++ b/internal/p2p/pqueue.go @@ -259,7 +259,6 @@ func (s *pqScheduler) process() { "chID", chIDStr, "peer_id", string(pqEnv.envelope.To)).Add(float64(pqEnv.size)) s.metrics.PeerPendingSendBytes.With( - "chID", chIDStr, "peer_id", string(pqEnv.envelope.To)).Add(float64(-pqEnv.size)) select { case s.dequeueCh <- pqEnv.envelope: