fix context deadline rejections (#13716)

prysmaticlabs · Mar 11, 2024 · cb8eb4e · cb8eb4e
1 parent 800f3b5
commit cb8eb4e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/beacon-chain/sync/subscriber.go b/beacon-chain/sync/subscriber.go
@@ -286,6 +286,11 @@ func (s *Service) wrapAndReportValidation(topic string, v wrappedVal) (string, p
 			return pubsub.ValidationIgnore
 		}
 		b, err := v(ctx, pid, msg)
+		// We do not penalize peers if we are hitting pubsub timeouts
+		// trying to process those messages.
+		if b == pubsub.ValidationReject && ctx.Err() != nil {
+			b = pubsub.ValidationIgnore
+		}
 		if b == pubsub.ValidationReject {
 			fields := logrus.Fields{
 				"topic":        topic,