From 3d8e484187d8be719718a472b74e78ab9cb1f202 Mon Sep 17 00:00:00 2001
From: Untone <anton.rewin@gmail.com>
Date: Sat, 18 May 2024 11:32:30 +0300
Subject: [PATCH] no-delete-index

---
 services/search.py | 17 +++--------------
 1 file changed, 3 insertions(+), 14 deletions(-)

diff --git a/services/search.py b/services/search.py
index de7416e3..df14b88c 100644
--- a/services/search.py
+++ b/services/search.py
@@ -91,7 +91,7 @@ class SearchService:
 
     def delete_index(self):
         if self.client:
-            logger.debug(f"Удаляем индекс {self.index_name}")
+            logger.warning(f"[!!!] Удаляем индекс {self.index_name}")
             self.client.indices.delete(index=self.index_name, ignore_unavailable=True)
 
     def create_index(self):
@@ -119,22 +119,11 @@ class SearchService:
                     mapping = result.get(self.index_name, {}).get("mappings")
                     if mapping and mapping != expected_mapping:
                         logger.debug(f"Найдена структура индексации: {mapping}")
-                        logger.warn(
-                            "Требуется другая структура индексации, переиндексация"
-                        )
-                        await self.recreate_index()
+                        logger.warn("[!!!] Требуется другая структура индексации и переиндексация данных")
+                        self.client = None
         else:
             logger.error("клиент не инициализован, невозможно проверить индекс")
 
-    async def recreate_index(self):
-        if self.client:
-            async with self.lock:
-                self.client.indices.delete(
-                    index=self.index_name, ignore_unavailable=True
-                )
-                await self.check_index()
-        else:
-            logger.error("клиент не инициализован, невозможно пересоздать индекс")
 
     def index(self, shout):
         if self.client: