feat(consensus): Don't resubscribe upstream if pre-genesis

ethpandaops · Jul 12, 2022 · 0a10f10 · 0a10f10
1 parent af18b3d
commit 0a10f10
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/exporter/consensus/beacon/subscriptions.go b/pkg/exporter/consensus/beacon/subscriptions.go
@@ -26,6 +26,11 @@ func (n *node) ensureBeaconSubscription(ctx context.Context) error {
 				continue
 			}
 
+			// Don't resubscribe if we are pre-genesis.
+			if !time.Now().After(n.genesis.GenesisTime) {
+				continue
+			}
+
 			n.log.
 				WithField("last_event_time", n.lastEventTime.Local().String()).
 				Info("Haven't received any events for 5 minutes, re-subscribing")