Demote logs in validator (#12564)

These logs are too annoying
erigontech · Nov 1, 2024 · 3a1c2a7 · 3a1c2a7
1 parent fe26f87
commit 3a1c2a7
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/cl/beacon/handler/validator_registration.go b/cl/beacon/handler/validator_registration.go
@@ -36,7 +36,7 @@ func (a *ApiHandler) PostEthV1ValidatorPrepareBeaconProposal(w http.ResponseWrit
 		return
 	}
 	for _, v := range req {
-		a.logger.Debug("[Caplin] Registered new proposer", "index", v.ValidatorIndex, "fee_recipient", v.FeeRecipient.String())
+		a.logger.Trace("[Caplin] Registered new proposer", "index", v.ValidatorIndex, "fee_recipient", v.FeeRecipient.String())
 		a.validatorParams.SetFeeRecipient(v.ValidatorIndex, v.FeeRecipient)
 		a.validatorsMonitor.ObserveValidator(v.ValidatorIndex)
 	}

diff --git a/cl/beacon/router.go b/cl/beacon/router.go
@@ -56,7 +56,7 @@ func ListenAndServe(beaconHandler *LayeredBeaconHandler, routerCfg beacon_router
 		if isNotFound(nfw.code) || nfw.code == 0 {
 			start := time.Now()
 			beaconHandler.ArchiveApi.ServeHTTP(w, r)
-			log.Debug("[Beacon API] Request", "uri", r.URL.String(), "path", r.URL.Path, "time", time.Since(start))
+			log.Trace("[Beacon API] Request", "uri", r.URL.String(), "path", r.URL.Path, "time", time.Since(start))
 		} else {
 			log.Warn("[Beacon API] Request to unavailable endpoint, check --beacon.api flag", "uri", r.URL.String(), "path", r.URL.Path)
 		}

diff --git a/cl/monitor/validator.go b/cl/monitor/validator.go
@@ -140,10 +140,10 @@ func (m *validatorMonitorImpl) runReportProposerStatus() {
 		if status := m.vaidatorStatuses.getValidatorStatus(proposerIndex, prevSlot/m.beaconCfg.SlotsPerEpoch); status != nil {
 			if status.proposeSlots.Contains(prevSlot) {
 				metricProposerHit.AddInt(1)
-				log.Info("[monitor] proposer hit", "slot", prevSlot, "proposerIndex", proposerIndex)
+				log.Warn("[monitor] proposer hit", "slot", prevSlot, "proposerIndex", proposerIndex)
 			} else {
 				metricProposerMiss.AddInt(1)
-				log.Info("[monitor] proposer miss", "slot", prevSlot, "proposerIndex", proposerIndex)
+				log.Warn("[monitor] proposer miss", "slot", prevSlot, "proposerIndex", proposerIndex)
 			}
 		}
 	}
@@ -196,7 +196,7 @@ func (s *validatorStatuses) addValidator(vid uint64) {
 	defer s.vStatusMutex.Unlock()
 	if _, ok := s.statuses[vid]; !ok {
 		s.statuses[vid] = make(map[uint64]*validatorStatus)
-		log.Info("[monitor] add validator", "vid", vid)
+		log.Trace("[monitor] add validator", "vid", vid)
 	}
 }
 
@@ -205,7 +205,7 @@ func (s *validatorStatuses) removeValidator(vid uint64) {
 	defer s.vStatusMutex.Unlock()
 	if _, ok := s.statuses[vid]; ok {
 		delete(s.statuses, vid)
-		log.Info("[monitor] remove validator", "vid", vid)
+		log.Trace("[monitor] remove validator", "vid", vid)
 	}
 }
 

diff --git a/cl/validator/committee_subscription/committee_subscription.go b/cl/validator/committee_subscription/committee_subscription.go
@@ -105,7 +105,7 @@ func (c *CommitteeSubscribeMgmt) AddAttestationSubscription(ctx context.Context,
 		return errors.New("head state not available")
 	}
 
-	log.Debug("Add attestation subscription", "slot", slot, "committeeIndex", cIndex, "isAggregator", p.IsAggregator, "validatorIndex", p.ValidatorIndex)
+	log.Trace("Add attestation subscription", "slot", slot, "committeeIndex", cIndex, "isAggregator", p.IsAggregator, "validatorIndex", p.ValidatorIndex)
 	commiteePerSlot := headState.CommitteeCount(p.Slot / c.beaconConfig.SlotsPerEpoch)
 	cn()
 	subnetId := subnets.ComputeSubnetForAttestation(commiteePerSlot, slot, cIndex, c.beaconConfig.SlotsPerEpoch, c.netConfig.AttestationSubnetCount)