handle error while sending in batch

osmosis-labs · Jan 17, 2024 · a6a6fcf · a6a6fcf
1 parent b334298
commit a6a6fcf
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/x/feeabs/keeper/ibc.go b/x/feeabs/keeper/ibc.go
@@ -274,6 +274,7 @@ func (k Keeper) handleOsmosisIbcQuery(ctx sdk.Context) error {
 	batchSize := 10
 	var reqs []types.QueryArithmeticTwapToNowRequest
 	batchCounter := 0
+	var errorFound error
 	k.IterateHostZone(ctx, func(hostZoneConfig types.HostChainFeeAbsConfig) (stop bool) {
 		if hostZoneConfig.Frozen {
 			return false
@@ -289,6 +290,7 @@ func (k Keeper) handleOsmosisIbcQuery(ctx sdk.Context) error {
 		if batchCounter == batchSize {
 			err := k.SendOsmosisQueryRequest(ctx, reqs, types.IBCPortID, params.IbcQueryIcqChannel)
 			if err != nil {
+				errorFound = err
 				return true
 			}
 			reqs = []types.QueryArithmeticTwapToNowRequest{}
@@ -297,6 +299,10 @@ func (k Keeper) handleOsmosisIbcQuery(ctx sdk.Context) error {
 		return false
 	})
 
+	if errorFound != nil {
+		return errorFound
+	}
+
 	if len(reqs) > 0 {
 		err := k.SendOsmosisQueryRequest(ctx, reqs, types.IBCPortID, params.IbcQueryIcqChannel)
 		if err != nil {