From 9b56067213b415af4cf447ff1a1f64b8ff70bb9c Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Fri, 29 Jan 2021 04:15:47 -0300 Subject: [PATCH] raise request timeout for content filtering --- lbry/wallet/server/db/elastic_search.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/lbry/wallet/server/db/elastic_search.py b/lbry/wallet/server/db/elastic_search.py index f376d42fd..95857aab8 100644 --- a/lbry/wallet/server/db/elastic_search.py +++ b/lbry/wallet/server/db/elastic_search.py @@ -94,17 +94,17 @@ class SearchIndex: } return update if filtered_streams: - await self.client.update_by_query(self.index, body=make_query(1, filtered_streams)) - await self.client.indices.refresh(self.index) + await self.client.update_by_query(self.index, body=make_query(1, filtered_streams), request_timeout=120) + await self.client.indices.refresh(self.index, request_timeout=120) if filtered_channels: - await self.client.update_by_query(self.index, body=make_query(1, filtered_channels, True)) - await self.client.indices.refresh(self.index) + await self.client.update_by_query(self.index, body=make_query(1, filtered_channels, True), request_timeout=120) + await self.client.indices.refresh(self.index, request_timeout=120) if blocked_streams: - await self.client.update_by_query(self.index, body=make_query(2, blocked_streams)) - await self.client.indices.refresh(self.index) + await self.client.update_by_query(self.index, body=make_query(2, blocked_streams), request_timeout=120) + await self.client.indices.refresh(self.index, request_timeout=120) if blocked_channels: - await self.client.update_by_query(self.index, body=make_query(2, blocked_channels, True)) - await self.client.indices.refresh(self.index) + await self.client.update_by_query(self.index, body=make_query(2, blocked_channels, True), request_timeout=120) + await self.client.indices.refresh(self.index, request_timeout=120) async def update(self, claims): if not claims: