This commit is contained in:
parent
520b43ee48
commit
9f9ea93526
|
@ -100,12 +100,15 @@ class SearchService:
|
||||||
try:
|
try:
|
||||||
if self.client:
|
if self.client:
|
||||||
if self.lock.acquire(blocking=False):
|
if self.lock.acquire(blocking=False):
|
||||||
|
try:
|
||||||
logger.debug(f' Создаём новый индекс: {self.index_name} ')
|
logger.debug(f' Создаём новый индекс: {self.index_name} ')
|
||||||
self.client.indices.create(
|
self.client.indices.create(
|
||||||
index=self.index_name, body=index_settings
|
index=self.index_name, body=index_settings
|
||||||
)
|
)
|
||||||
self.client.indices.close(index=self.index_name)
|
self.client.indices.close(index=self.index_name)
|
||||||
self.client.indices.open(index=self.index_name)
|
self.client.indices.open(index=self.index_name)
|
||||||
|
finally:
|
||||||
|
self.lock.release()
|
||||||
else:
|
else:
|
||||||
logger.debug('..')
|
logger.debug('..')
|
||||||
except Exception as error:
|
except Exception as error:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user