From aaf746d6dc706535cdaa317db2a2b02933313522 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 9 May 2023 17:02:44 +0800 Subject: [PATCH] max seq --- pkg/common/db/cache/msg.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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))