feat(conversation_service): add asynchronous and synchronous methods for initializing conversation search index

- Introduced `init_conversation_search_index_async` and `init_conversation_search_index` methods to create the conversation search index, allowing for repeated calls if the index already exists.
- Updated references in `session_store.py` and `ots_backend.py` to utilize the new methods for initializing the conversation search index.

This enhancement improves the flexibility and usability of the conversation service's indexing capabilities.

Author: TJKkking

agentrun/conversation_service/__ots_backend_async_template.py

@@ -181,6 +181,13 @@ async def init_search_index_async(self) -> None:
         await self._create_conversation_search_index_async()
         await self._create_state_search_index_async()
 
+    async def init_conversation_search_index_async(self) -> None:
+        """仅创建 Conversation 多元索引（异步）。
+
+        索引已存在时跳过，可重复调用。
+        """
+        await self._create_conversation_search_index_async()
+
     async def init_checkpoint_tables_async(self) -> None:
         """创建 LangGraph checkpoint 相关的 3 张表（异步）。
 

agentrun/conversation_service/__session_store_async_template.py

@@ -71,7 +71,7 @@ async def init_langchain_tables_async(self) -> None:
         表或索引已存在时跳过，可重复调用。
         """
         await self._backend.init_core_tables_async()
-        await self._backend.init_search_index_async()
+        await self._backend.init_conversation_search_index_async()
 
     async def init_langgraph_tables_async(self) -> None:
         """创建 LangGraph 所需的全部表和索引（异步）。
@@ -81,7 +81,7 @@ async def init_langgraph_tables_async(self) -> None:
         表或索引已存在时跳过，可重复调用。
         """
         await self._backend.init_core_tables_async()
-        await self._backend.init_search_index_async()
+        await self._backend.init_conversation_search_index_async()
         await self._backend.init_checkpoint_tables_async()
 
     async def init_adk_tables_async(self) -> None:

agentrun/conversation_service/ots_backend.py

@@ -249,6 +249,20 @@ def init_search_index(self) -> None:
         self._create_conversation_search_index()
         self._create_state_search_index()
 
+    async def init_conversation_search_index_async(self) -> None:
+        """仅创建 Conversation 多元索引（异步）。
+
+        索引已存在时跳过，可重复调用。
+        """
+        await self._create_conversation_search_index_async()
+
+    def init_conversation_search_index(self) -> None:
+        """仅创建 Conversation 多元索引（同步）。
+
+        索引已存在时跳过，可重复调用。
+        """
+        self._create_conversation_search_index()
+
     async def init_checkpoint_tables_async(self) -> None:
         """创建 LangGraph checkpoint 相关的 3 张表（异步）。
 

agentrun/conversation_service/session_store.py

@@ -111,7 +111,7 @@ async def init_langchain_tables_async(self) -> None:
         表或索引已存在时跳过，可重复调用。
         """
         await self._backend.init_core_tables_async()
-        await self._backend.init_search_index_async()
+        await self._backend.init_conversation_search_index_async()
 
     def init_langchain_tables(self) -> None:
         """创建 LangChain 所需的全部表和索引（同步）。
@@ -120,7 +120,7 @@ def init_langchain_tables(self) -> None:
         表或索引已存在时跳过，可重复调用。
         """
         self._backend.init_core_tables()
-        self._backend.init_search_index()
+        self._backend.init_conversation_search_index()
 
     async def init_langgraph_tables_async(self) -> None:
         """创建 LangGraph 所需的全部表和索引（异步）。
@@ -130,7 +130,7 @@ async def init_langgraph_tables_async(self) -> None:
         表或索引已存在时跳过，可重复调用。
         """
         await self._backend.init_core_tables_async()
-        await self._backend.init_search_index_async()
+        await self._backend.init_conversation_search_index_async()
         await self._backend.init_checkpoint_tables_async()
 
     def init_langgraph_tables(self) -> None:
@@ -141,7 +141,7 @@ def init_langgraph_tables(self) -> None:
         表或索引已存在时跳过，可重复调用。
         """
         self._backend.init_core_tables()
-        self._backend.init_search_index()
+        self._backend.init_conversation_search_index()
         self._backend.init_checkpoint_tables()
 
     async def init_adk_tables_async(self) -> None: