From 61fc375ce86c02f5577ac61ce7ead3175a7c20b1 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 24 Jul 2024 14:41:50 +0800 Subject: [PATCH] fix: batchGetMaxSeq --- pkg/common/storage/cache/redis/seq_conversation.go | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/pkg/common/storage/cache/redis/seq_conversation.go b/pkg/common/storage/cache/redis/seq_conversation.go index 7e75bff3f..7fe849193 100644 --- a/pkg/common/storage/cache/redis/seq_conversation.go +++ b/pkg/common/storage/cache/redis/seq_conversation.go @@ -77,15 +77,13 @@ func (s *seqConversationCacheRedis) batchGetMaxSeq(ctx context.Context, keys []s return errs.Wrap(err) } } - if len(notFoundKey) > 0 { - for _, key := range notFoundKey { - conversationID := keyConversationID[key] - seq, err := s.GetMaxSeq(ctx, conversationID) - if err != nil { - return err - } - seqs[conversationID] = seq + for _, key := range notFoundKey { + conversationID := keyConversationID[key] + seq, err := s.GetMaxSeq(ctx, conversationID) + if err != nil { + return err } + seqs[conversationID] = seq } return nil }