mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2025-01-08 18:51:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Improve validator logs (#5140)

Browse Source 
* Imporve validator logging

* Update validator/client/validator_log.go
This commit is contained in:
Ivan Martinez 2020-03-19 13:34:50 -04:00 committed by GitHub
parent 6fe814c5aa
commit 271938202e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
validator/client/validator.go
View File

@ -135,7 +135,6 @@ func (v *validator) WaitForActivation(ctx context.Context) error {
if err != nil { if err != nil {
return errors.Wrap(err, "could not receive validator activation from stream") return errors.Wrap(err, "could not receive validator activation from stream")
} }
log.Info("Waiting for validator to be activated in the beacon chain")
activatedKeys := v.checkAndLogValidatorStatus(res.Statuses) activatedKeys := v.checkAndLogValidatorStatus(res.Statuses)
if len(activatedKeys) > 0 { if len(activatedKeys) > 0 {
@ -206,6 +205,10 @@ func (v *validator) checkAndLogValidatorStatus(validatorStatuses []*ethpb.Valida
"Deposit for validator received but not processed into state") "Deposit for validator received but not processed into state")
continue continue
} }
if status.Status.DepositInclusionSlot == 0 && status.Status.PositionInActivationQueue == 0 {
log.Info("Waiting for deposit to be seen")
continue
}
if uint64(status.Status.ActivationEpoch) == params.BeaconConfig().FarFutureEpoch { if uint64(status.Status.ActivationEpoch) == params.BeaconConfig().FarFutureEpoch {
log.WithFields(logrus.Fields{ log.WithFields(logrus.Fields{
"depositInclusionSlot": status.Status.DepositInclusionSlot, "depositInclusionSlot": status.Status.DepositInclusionSlot,
@ -268,6 +271,8 @@ func (v *validator) UpdateDuties(ctx context.Context, slot uint64) error {
PublicKeys: bytesutil.FromBytes48Array(validatingKeys), PublicKeys: bytesutil.FromBytes48Array(validatingKeys),
} }
// If duties is nil it means we have had no prior duties and just started up.
firstDutiesReceived := v.duties == nil
resp, err := v.validatorClient.GetDuties(ctx, req) resp, err := v.validatorClient.GetDuties(ctx, req)
if err != nil { if err != nil {
v.duties = nil // Clear assignments so we know to retry the request. v.duties = nil // Clear assignments so we know to retry the request.
@ -277,7 +282,8 @@ func (v *validator) UpdateDuties(ctx context.Context, slot uint64) error {
v.duties = resp v.duties = resp
// Only log the full assignments output on epoch start to be less verbose. // Only log the full assignments output on epoch start to be less verbose.
if slot%params.BeaconConfig().SlotsPerEpoch == 0 { // Also log out on first launch so the user doesn't have to wait a whole epoch to see their assignments.
if slot%params.BeaconConfig().SlotsPerEpoch == 0 || firstDutiesReceived {
for _, duty := range v.duties.Duties { for _, duty := range v.duties.Duties {
lFields := logrus.Fields{ lFields := logrus.Fields{
"pubKey": fmt.Sprintf("%#x", bytesutil.Trunc(duty.PublicKey)), "pubKey": fmt.Sprintf("%#x", bytesutil.Trunc(duty.PublicKey)),