diff --git a/pkg/common/db/cache/msg.go b/pkg/common/db/cache/msg.go index fb2850dff..2f717bbcd 100644 --- a/pkg/common/db/cache/msg.go +++ b/pkg/common/db/cache/msg.go @@ -146,12 +146,13 @@ func (c *msgCache) getSeq(ctx context.Context, conversationID string, getkey fun func (c *msgCache) getSeqs(ctx context.Context, items []string, getkey func(s string) string) (m map[string]int64, err error) { pipe := c.rdb.Pipeline() for _, v := range items { + log.ZDebug(ctx, "getSeqs", "getkey", getkey(v)) if err := pipe.Get(ctx, getkey(v)).Err(); err != nil && err != redis.Nil { return nil, errs.Wrap(err) } } result, err := pipe.Exec(ctx) - if err != nil { + if err != nil && err != redis.Nil { return nil, errs.Wrap(err) } m = make(map[string]int64, len(items))