read the returned error

cosmos · Sep 26, 2024 · 34364b4 · 34364b4
1 parent bab2d54
commit 34364b4
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/x/ccv/provider/keeper/distribution.go b/x/ccv/provider/keeper/distribution.go
@@ -314,7 +314,15 @@ func (k Keeper) AllocateTokens(ctx sdk.Context) {
 				)
 				continue
 			}
-			k.SetConsumerRewardsAllocationByDenom(cachedCtx, consumerId, denom, allocatedRewards)
+			err = k.SetConsumerRewardsAllocationByDenom(cachedCtx, consumerId, denom, allocatedRewards)
+			if err != nil {
+				k.Logger(ctx).Error(
+					"fail to set rewards for consumer chain",
+					"consumer id", consumerId,
+					"error", err.Error(),
+				)
+				continue
+			}
 			writeCache()
 		}
 	}