From 765cdc2ec2bcb79f69eb474ccc251540f95e6e53 Mon Sep 17 00:00:00 2001
From: "Ramin M." <58203645+raminmardani@users.noreply.github.com>
Date: Mon, 11 May 2026 18:31:47 -0700
Subject: [PATCH] [Bug]: REDIS error #12870 (#13875)

Fix for: [Bug]: REDIS error #12870
---
 memory/services/query.py | 4 ++--
 rag/nlp/query.py         | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/memory/services/query.py b/memory/services/query.py
index 0e97f1fc2..e2bce608b 100644
--- a/memory/services/query.py
+++ b/memory/services/query.py
@@ -21,7 +21,7 @@ from common.query_base import QueryBase
 from common.doc_store.doc_store_base import MatchDenseExpr, MatchTextExpr
 from common.float_utils import get_float
 from rag.nlp import rag_tokenizer, term_weight, synonym
-
+from rag.utils.redis_conn import REDIS_CONN
 
 def get_vector(txt, emb_mdl, topk=10, similarity=0.1):
     if isinstance(similarity, str) and len(similarity) > 0:
@@ -44,7 +44,7 @@ class MsgTextQuery(QueryBase):
 
     def __init__(self):
         self.tw = term_weight.Dealer()
-        self.syn = synonym.Dealer()
+        self.syn = synonym.Dealer(redis=REDIS_CONN.REDIS if REDIS_CONN.is_alive() else None)
         self.query_fields = [
             "content"
         ]
diff --git a/rag/nlp/query.py b/rag/nlp/query.py
index 2d50eea34..db04eb375 100644
--- a/rag/nlp/query.py
+++ b/rag/nlp/query.py
@@ -22,12 +22,13 @@ from collections import defaultdict
 from common.query_base import QueryBase
 from common.doc_store.doc_store_base import MatchTextExpr
 from rag.nlp import rag_tokenizer, term_weight, synonym
+from rag.utils.redis_conn import REDIS_CONN
 
 
 class FulltextQueryer(QueryBase):
     def __init__(self):
         self.tw = term_weight.Dealer()
-        self.syn = synonym.Dealer()
+        self.syn = synonym.Dealer(redis=REDIS_CONN.REDIS if REDIS_CONN.is_alive() else None)
         self.query_fields = [
             "title_tks^10",
             "title_sm_tks^5",