log error rather than panic on invalid subscriber

PeggyJV · Feb 3, 2024 · aea55eb · aea55eb
1 parent df8a077
commit aea55eb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/x/pubsub/keeper/keeper.go b/x/pubsub/keeper/keeper.go
@@ -170,7 +170,8 @@ func (k Keeper) GetValidatorSubscribers(ctx sdk.Context) (subscribers []*types.S
 	for _, subscriber := range allSubscribers {
 		subscriberAddress, err := sdk.AccAddressFromBech32(subscriber.Address)
 		if err != nil {
-			panic(fmt.Errorf("subscriber address %s not valid bech32 but in state", subscriberAddress))
+			ctx.Logger().Error("subscriber address %s not valid bech32 but in state", subscriber.Address)
+			continue
 		}
 		var validatorI stakingtypes.ValidatorI
 		if validator := k.gravityKeeper.GetOrchestratorValidatorAddress(ctx, subscriberAddress); validator == nil {