From cda2908e1fb1f0b5151d70e4aee5046d141e5f85 Mon Sep 17 00:00:00 2001 From: Sam Calder-Mason Date: Mon, 4 Sep 2023 11:51:53 +1000 Subject: [PATCH] fix(sentry): Fix broken BeaconCommittee events --- pkg/sentry/beacon_committees.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/pkg/sentry/beacon_committees.go b/pkg/sentry/beacon_committees.go index 0c1277b4..eba37b00 100644 --- a/pkg/sentry/beacon_committees.go +++ b/pkg/sentry/beacon_committees.go @@ -59,15 +59,15 @@ func (s *Sentry) startBeaconCommitteesWatcher(ctx context.Context) error { func (s *Sentry) createNewBeaconCommitteeEvent(ctx context.Context, epoch phase0.Epoch, committees []*eth2v1.BeaconCommittee) error { now := time.Now() - meta, err := s.createNewClientMeta(ctx) - if err != nil { - s.log.WithError(err).Error("Failed to create client meta when handling beacon committee event") - - return err - } - // Create an event for every committee. for _, committee := range committees { + meta, err := s.createNewClientMeta(ctx) + if err != nil { + s.log.WithError(err).Error("Failed to create client meta when handling beacon committee event") + + continue + } + event := v1.NewBeaconCommittee(s.log, committee, epoch, now, s.beacon, meta, s.duplicateCache.BeaconEthV1BeaconCommittee) decoratedEvent, err := event.Decorate(ctx)