From 9f9ea93526a907a9de3e46dd883b7dfe04e5b962 Mon Sep 17 00:00:00 2001 From: Untone Date: Mon, 29 Jan 2024 06:52:51 +0300 Subject: [PATCH] release-lock-fix --- services/search.py | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/services/search.py b/services/search.py index 15406fe9..b30624ac 100644 --- a/services/search.py +++ b/services/search.py @@ -100,12 +100,15 @@ class SearchService: try: if self.client: if self.lock.acquire(blocking=False): - logger.debug(f' Создаём новый индекс: {self.index_name} ') - self.client.indices.create( - index=self.index_name, body=index_settings - ) - self.client.indices.close(index=self.index_name) - self.client.indices.open(index=self.index_name) + try: + logger.debug(f' Создаём новый индекс: {self.index_name} ') + self.client.indices.create( + index=self.index_name, body=index_settings + ) + self.client.indices.close(index=self.index_name) + self.client.indices.open(index=self.index_name) + finally: + self.lock.release() else: logger.debug('..') except Exception as error: