fixup

gobitfly · Jan 14, 2025 · 2e6e7f9 · 2e6e7f9
1 parent b7c1d8f
commit 2e6e7f9
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/backend/pkg/exporter/modules/execution_payloads_exporter.go b/backend/pkg/exporter/modules/execution_payloads_exporter.go
@@ -160,18 +160,27 @@ func (d *executionPayloadsExporter) maintainTable() (err error) {
 	seen := make(map[string]bool)
 	emptyBlockHash := bytes.Repeat([]byte{0}, 32)
 	err = error(nil)
+	counter := 0
 	for _, r := range resData {
+		if counter > 25 {
+			err = fmt.Errorf("too many errors, aborting")
+			log.Error(err, "error processing blocks", 0)
+			break
+		}
 		if len(r.BlockHash) == 0 {
 			err = fmt.Errorf("error processing blocks: block hash is empty, block number: %v", r.BlockNumber)
 			log.Error(err, "error processing blocks", 0)
+			counter++
 		}
 		if bytes.Equal(r.BlockHash, emptyBlockHash) {
 			err = fmt.Errorf("error processing blocks: block hash is all zeros, block number: %v", r.BlockNumber)
 			log.Error(err, "error processing blocks", 0)
+			counter++
 		}
 		if _, ok := seen[string(r.BlockHash)]; ok {
 			err = fmt.Errorf("error processing blocks: duplicate block hash, block number: %v", r.BlockNumber)
 			log.Error(err, "error processing blocks", 0)
+			counter++
 		}
 		seen[string(r.BlockHash)] = true
 	}