mirror of
https://github.com/OffchainLabs/prysm.git
synced 2026-01-10 07:58:22 -05:00
Only log error when aggregator check fails (#14046)
* Only log error when aggregator check fails * review
This commit is contained in:
@@ -705,7 +705,8 @@ func (v *validator) RolesAt(ctx context.Context, slot primitives.Slot) (map[[fie
|
||||
|
||||
aggregator, err := v.isAggregator(ctx, duty.Committee, slot, bytesutil.ToBytes48(duty.PublicKey), duty.ValidatorIndex)
|
||||
if err != nil {
|
||||
return nil, errors.Wrap(err, "could not check if a validator is an aggregator")
|
||||
aggregator = false
|
||||
log.WithError(err).Errorf("Could not check if validator %#x is an aggregator", bytesutil.Trunc(duty.PublicKey))
|
||||
}
|
||||
if aggregator {
|
||||
roles = append(roles, iface.RoleAggregator)
|
||||
@@ -730,7 +731,8 @@ func (v *validator) RolesAt(ctx context.Context, slot primitives.Slot) (map[[fie
|
||||
if inSyncCommittee {
|
||||
aggregator, err := v.isSyncCommitteeAggregator(ctx, slot, bytesutil.ToBytes48(duty.PublicKey), duty.ValidatorIndex)
|
||||
if err != nil {
|
||||
return nil, errors.Wrap(err, "could not check if a validator is a sync committee aggregator")
|
||||
aggregator = false
|
||||
log.WithError(err).Errorf("Could not check if validator %#x is an aggregator", bytesutil.Trunc(duty.PublicKey))
|
||||
}
|
||||
if aggregator {
|
||||
roles = append(roles, iface.RoleSyncCommitteeAggregator)
|
||||
|
||||
Reference in New Issue
Block a user