ignore errors when deleting

This commit is contained in:
Victor Shyba 2021-01-19 04:50:31 -03:00
parent 996686c1da
commit dc10f8ce72

View file

@ -67,7 +67,7 @@ class SearchIndex:
if not claim_ids: if not claim_ids:
return return
actions = [{'_index': self.index, '_op_type': 'delete', '_id': claim_id} for claim_id in claim_ids] actions = [{'_index': self.index, '_op_type': 'delete', '_id': claim_id} for claim_id in claim_ids]
await async_bulk(self.client, actions) await async_bulk(self.client, actions, raise_on_error=False)
update = expand_query(channel_id__in=claim_ids) update = expand_query(channel_id__in=claim_ids)
update['script'] = { update['script'] = {
"source": "ctx._source.signature_valid=false", "source": "ctx._source.signature_valid=false",