From b566232f67c7a6aadf4cb8946960d9c7de149c2f Mon Sep 17 00:00:00 2001 From: "Alessandro (Ale) Segala" <43508+ItalyPaleAle@users.noreply.github.com> Date: Fri, 23 Sep 2022 21:59:50 -0700 Subject: [PATCH] Remove recover from Redis config store (#2124) Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com> Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com> Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com> --- configuration/redis/redis.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/configuration/redis/redis.go b/configuration/redis/redis.go index fae9e5873..8e1754f90 100644 --- a/configuration/redis/redis.go +++ b/configuration/redis/redis.go @@ -312,11 +312,6 @@ func (r *ConfigurationStore) doSubscribe(ctx context.Context, req *configuration } func (r *ConfigurationStore) handleSubscribedChange(ctx context.Context, req *configuration.SubscribeRequest, handler configuration.UpdateHandler, msg *redis.Message, id string) { - defer func() { - if err := recover(); err != nil { - r.logger.Errorf("panic in handleSubscribedChange(）method and recovered: %s", err) - } - }() targetKey, err := internal.ParseRedisKeyFromEvent(msg.Channel) if err != nil { r.logger.Errorf("parse redis key failed: %s", err)