diff --git a/pkg/common/storage/cache/redis/seq_conversation.go b/pkg/common/storage/cache/redis/seq_conversation.go index fb8a547df..7e75bff3f 100644 --- a/pkg/common/storage/cache/redis/seq_conversation.go +++ b/pkg/common/storage/cache/redis/seq_conversation.go @@ -78,12 +78,14 @@ func (s *seqConversationCacheRedis) batchGetMaxSeq(ctx context.Context, keys []s } } if len(notFoundKey) > 0 { - conversationID := keyConversationID[notFoundKey[0]] - seq, err := s.GetMaxSeq(ctx, conversationID) - if err != nil { - return err + for _, key := range notFoundKey { + conversationID := keyConversationID[key] + seq, err := s.GetMaxSeq(ctx, conversationID) + if err != nil { + return err + } + seqs[conversationID] = seq } - seqs[conversationID] = seq } return nil }