discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

recreate-fixed-4

Browse Source
This commit is contained in:
Untone 2024-02-29 14:48:08 +03:00
parent c8acf6a9ac
commit cb85e24a11
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
services/search.py
View File

@ -54,6 +54,7 @@ class SearchService:
def __init__(self, index_name='search_index'): def __init__(self, index_name='search_index'):
self.index_name = index_name self.index_name = index_name
self.client = None self.client = None
self.lock = asyncio.Lock() # Create an asyncio lock
# Only initialize the instance if it's not already initialized # Only initialize the instance if it's not already initialized
if ELASTIC_HOST: if ELASTIC_HOST:
@ -112,8 +113,8 @@ class SearchService:
await self.recreate_index() await self.recreate_index()
async def recreate_index(self): async def recreate_index(self):
async with asyncio.Lock(): async with self.lock:
self.delete_index() self.client.indices.delete(index=self.index_name, ignore_unavailable=True)
await self.check_index() await self.check_index()
def index(self, shout): def index(self, shout):