From 30325cea8df09068f0b3886951bb6afbe5bc9bb5 Mon Sep 17 00:00:00 2001
From: Giulio Carvalho <giulioccavalcante@gmail.com>
Date: Thu, 14 Dec 2023 18:06:33 -0300
Subject: [PATCH] =?UTF-8?q?Corrige=20exclus=C3=A3o=20de=20scroll=5Fid's=20?=
 =?UTF-8?q?n=C3=A3o=20usados?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

O Opensearch de produção ainda está dando erro de scroll_id's e foi
identificado que a paginação não estava os excluindo corretamente.
---
 index/opensearch.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/index/opensearch.py b/index/opensearch.py
index 941e248..6684bd2 100644
--- a/index/opensearch.py
+++ b/index/opensearch.py
@@ -74,8 +74,13 @@ def paginated_search(
         if len(result["hits"]["hits"]) == 0:
             return
 
+        scroll_id = None
         while len(result["hits"]["hits"]) > 0:
             yield result
+
+            if scroll_id is not None and scroll_id != result["_scroll_id"]:
+                self._search_engine.clear_scroll(scroll_id=scroll_id)
+
             scroll_id = result["_scroll_id"]
             result = self._search_engine.scroll(
                 scroll_id=scroll_id, scroll=keep_alive, request_timeout=120