feat: reenable retry

yearn · Nov 27, 2023 · b9be735 · b9be735
1 parent 3eff783
commit b9be735
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/internal/indexer/indexer.registries.go b/internal/indexer/indexer.registries.go
@@ -356,7 +356,7 @@ func indexNewVaultsWrapper(
 	** indexer to be able to catch the errors, to restart the indexer or just to exit the loop to
 	** fallback to another method.
 	**********************************************************************************************/
-	shouldRetry := false
+	shouldRetry := true
 	err := error(nil)
 	for {
 		if _, err := ethereum.GetWSClient(chainID); err != nil {
@@ -392,6 +392,7 @@ func indexNewVaultsWrapper(
 			logs.Error(`error while indexing NewVault from registry ` + registry.Address.Hex() + ` on chain ` + strconv.FormatUint(chainID, 10) + `: ` + err.Error())
 		}
 		if shouldRetry {
+			time.Sleep(30 * time.Second)
 			continue
 		}
 		break

diff --git a/internal/indexer/indexer.stakingPools.go b/internal/indexer/indexer.stakingPools.go
@@ -173,7 +173,7 @@ func indexStakingPoolWrapper(
 	** indexer to be able to catch the errors, to restart the indexer or just to exit the loop to
 	** fallback to another method.
 	**********************************************************************************************/
-	shouldRetry := false
+	shouldRetry := true
 	err := error(nil)
 
 	for {
@@ -210,6 +210,7 @@ func indexStakingPoolWrapper(
 			logs.Error(`error while indexing staking pools from registry ` + registry.Address.Hex() + ` on chain ` + strconv.FormatUint(chainID, 10) + `: ` + err.Error())
 		}
 		if shouldRetry {
+			time.Sleep(30 * time.Second)
 			continue
 		}
 		break

diff --git a/internal/indexer/indexer.strategies.go b/internal/indexer/indexer.strategies.go
@@ -499,7 +499,7 @@ func indexStrategyWrapper(
 	** indexer to be able to catch the errors, to restart the indexer or just to exit the loop to
 	** fallback to another method.
 	**********************************************************************************************/
-	shouldRetry := false
+	shouldRetry := true
 	err := error(nil)
 
 	for {
@@ -536,6 +536,7 @@ func indexStrategyWrapper(
 			logs.Error(`error while indexing New Strategies from vault ` + vault.Address.Hex() + ` on chain ` + strconv.FormatUint(chainID, 10) + `: ` + err.Error())
 		}
 		if shouldRetry {
+			time.Sleep(30 * time.Second)
 			continue
 		}
 		break