Skip to content

Commit 2381b17

Browse files
committed
fix: channel ensure index exists
1 parent 8fd459c commit 2381b17

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

src/backend/bisheng/channel/domain/services/article_es_service.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,9 @@ async def _get_client(self) -> AsyncElasticsearch:
4040

4141
async def ensure_index(self) -> None:
4242
"""Ensure article index exists"""
43-
client = await self._get_client()
44-
await ensure_article_index_exists(client)
43+
if self._es_client is None:
44+
self._es_client = await get_es_connection()
45+
await ensure_article_index_exists(self._es_client)
4546

4647
@staticmethod
4748
def ensure_index_sync() -> None:

0 commit comments

Comments
 (0)