Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

report deletions on docs that doesnt exist, but dont raise

Browse source
This commit is contained in:
Victor Shyba 2021-03-08 01:29:08 -03:00
parent 4d83d42b4c
commit f26394fd3b
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbry/wallet/server/db/elastic_search.py
View file

@ -101,7 +101,8 @@ class SearchIndex:
async def claim_consumer(self, claim_producer): async def claim_consumer(self, claim_producer):
await self.client.indices.refresh(self.index) await self.client.indices.refresh(self.index)
touched = set() touched = set()
async for ok, item in async_streaming_bulk(self.client, self._consume_claim_producer(claim_producer)): async for ok, item in async_streaming_bulk(self.client, self._consume_claim_producer(claim_producer),
raise_on_error=False):
if not ok: if not ok:
self.logger.warning("indexing failed for an item: %s", item) self.logger.warning("indexing failed for an item: %s", item)
else: else:
@ -283,8 +284,10 @@ class SearchIndex:
claim_id = url.stream.claim_id claim_id = url.stream.claim_id
else: else:
claim_id = await self.full_id_from_short_id(query['name'], query['claim_id'], channel_id) claim_id = await self.full_id_from_short_id(query['name'], query['claim_id'], channel_id)
if claim_id:
stream = await self.get_many(claim_id) stream = await self.get_many(claim_id)
return stream[0] if len(stream) else None return stream[0] if len(stream) else None
return None
if channel_id is not None: if channel_id is not None:
if set(query) == {'name'}: if set(query) == {'name'}: