Merge pull request #504 from paritytech/AndreiEres/retry-on-rpc-error

Retry on RPC error
paritytech · Aug 21, 2023 · 102030a · 102030a
2 parents 1e8d8ca + 1af3668
commit 102030a
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/essentials/src/api/subxt_wrapper.rs b/essentials/src/api/subxt_wrapper.rs
@@ -22,7 +22,7 @@ use crate::{
 	types::{AccountId32, BlockNumber, ClaimQueue, CoreOccupied, SessionKeys, Timestamp, H256},
 	utils::{Retry, RetryOptions},
 };
-use log::error;
+use log::{error, warn};
 use std::{
 	collections::{hash_map::HashMap, BTreeMap},
 	fmt::Debug,
@@ -274,12 +274,14 @@ impl RequestExecutor {
 			if let Err(e) = reply {
 				let need_to_retry = matches!(
 					e,
-					SubxtWrapperError::SubxtError(subxt::Error::Io(_)) | SubxtWrapperError::NoResponseFromDynamicApi(_)
+					SubxtWrapperError::SubxtError(subxt::Error::Io(_)) |
+						SubxtWrapperError::SubxtError(subxt::Error::Rpc(_)) |
+						SubxtWrapperError::NoResponseFromDynamicApi(_)
 				);
 				if !need_to_retry {
 					return Err(e)
 				}
-				error!("[{}] Subxt error: {:?}", url, e);
+				warn!("[{}] Subxt error: {:?}", url, e);
 				connection_pool.remove(url);
 				if (retry.sleep().await).is_err() {
 					return Err(SubxtWrapperError::Timeout)