diff --git a/backend/common/src/es_connect.py b/backend/common/src/es_connect.py index b2d11635..ecd46661 100644 --- a/backend/common/src/es_connect.py +++ b/backend/common/src/es_connect.py @@ -168,7 +168,7 @@ class IndexPaginate: def get_pit(self): """get pit for index""" - path = f"{self.index_name}/_pit?keep_alive=10m" + path = f"{self.index_name}/_pit?keep_alive=15m" response, _ = ElasticWrap(path).post() self.pit_id = response["id"] @@ -184,7 +184,7 @@ class IndexPaginate: self.data.update({"sort": [{"_doc": {"order": "desc"}}]}) self.data["size"] = self.kwargs.get("size") or self.DEFAULT_SIZE - self.data["pit"] = {"id": self.pit_id, "keep_alive": "10m"} + self.data["pit"] = {"id": self.pit_id, "keep_alive": "15m"} def run_loop(self): """loop through results until last hit""" diff --git a/backend/video/src/meta_embed.py b/backend/video/src/meta_embed.py index 21f9b3f7..fb8bcc33 100644 --- a/backend/video/src/meta_embed.py +++ b/backend/video/src/meta_embed.py @@ -44,7 +44,7 @@ class MetadataEmbed: paginate = IndexPaginate( index_name=self.INDEX_NAME, data=data, - size=200, + size=100, callback=MetadataEmbedCallback, task=self.task, total=self._get_total(),