fix synchronizer when epoch duties can't be loaded from any client

ethpandaops · Jun 21, 2024 · c05f943 · c05f943
1 parent 78a52c4
commit c05f943
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/indexer/synchronizer.go b/indexer/synchronizer.go
@@ -208,7 +208,10 @@ func (sync *synchronizerState) syncEpoch(syncEpoch uint64, retryCount int, lastT
 	}
 
 	epochAssignments, err := client.rpcClient.GetEpochAssignments(syncEpoch, dependentRoot)
-	if err != nil || epochAssignments == nil {
+	if (err != nil || epochAssignments == nil) && !lastTry {
+		return false, client, fmt.Errorf("error fetching epoch %v duties: %v", syncEpoch, err)
+	}
+	if epochAssignments == nil {
 		return false, client, fmt.Errorf("error fetching epoch %v duties: %v", syncEpoch, err)
 	}
 	if len(epochAssignments.ProposerAssignments) == 0 && !lastTry {

diff --git a/services/validatornames.go b/services/validatornames.go
@@ -496,7 +496,7 @@ func (vn *ValidatorNames) updateDb() error {
 		}
 
 		if len(updateNames) > 0 || len(removeIndexes) > 0 {
-			logger_vn.Infof("update validator names %v-%v: %v changed, %v removed", lastIndex, maxIdx, len(updateNames), len(removeIndexes))
+			logger_vn.Infof("update validator names %v-%v: %v changed, %v removed", lastIndex, maxIndex, len(updateNames), len(removeIndexes))
 			time.Sleep(2 * time.Second)
 		} else {
 			time.Sleep(100 * time.Millisecond)