retry el block processing on failure (wait for execution)

ethpandaops · Jan 17, 2024 · 42fe4f2 · 42fe4f2
1 parent dcec87d
commit 42fe4f2
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/pkg/coordinator/clients/execution/clientlogic.go b/pkg/coordinator/clients/execution/clientlogic.go
@@ -118,7 +118,21 @@ func (client *Client) runClientLogic() error {
 
 		select {
 		case updateNotification := <-client.updateChan:
-			err := client.processBlock(updateNotification.hash, updateNotification.number, nil, "notified")
+			var err error
+
+			retryCount := 0
+
+			for retryCount < 3 {
+				err = client.processBlock(updateNotification.hash, updateNotification.number, nil, "notified")
+				if err == nil {
+					break
+				}
+
+				retryCount++
+
+				time.Sleep(1 * time.Second)
+			}
+
 			if err != nil {
 				client.logger.Warnf("error processing execution block update: %v", err)
 			} else {