From c05f943edca910106708243c5a7794fa78696d16 Mon Sep 17 00:00:00 2001 From: pk910 Date: Sat, 22 Jun 2024 00:39:34 +0200 Subject: [PATCH] fix synchronizer when epoch duties can't be loaded from any client --- indexer/synchronizer.go | 5 ++++- services/validatornames.go | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/indexer/synchronizer.go b/indexer/synchronizer.go index 31b9b5ce..c143b1ed 100644 --- 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 index 3e039aae..1591503a 100644 --- 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)