diff --git a/rag/nlp/search.py b/rag/nlp/search.py
index 3580f2236..86b02d78d 100644
--- a/rag/nlp/search.py
+++ b/rag/nlp/search.py
@@ -449,7 +449,7 @@ class Dealer:
         return res
 
     def all_tags(self, tenant_id: str, kb_ids: list[str], S=1000):
-        if not self.docStoreConn.indexExist(index_name(tenant_id), kb_ids[0]):
+        if not self.dataStore.indexExist(index_name(tenant_id), kb_ids[0]):
             return []
         res = self.dataStore.search([], [], {}, [], OrderByExpr(), 0, 0, index_name(tenant_id), kb_ids, ["tag_kwd"])
         return self.dataStore.getAggregation(res, "tag_kwd")