fix uncaught error in es sync

This commit is contained in:
Jack Robison 2022-10-29 17:14:41 -04:00
parent 6932c38854
commit 98017e9a76
2 changed files with 2 additions and 2 deletions

View file

@ -790,7 +790,7 @@ class SecondaryDB:
for touched in claim_hashes: for touched in claim_hashes:
extra = {} extra = {}
claim_txo = claims[touched] claim_txo = claims[touched]
if not claim_txo: if not claim_txo or (claim_txo and not controlling_claims[claim_txo.normalized_name]):
yield touched, None, extra yield touched, None, extra
continue continue
if touched in total_extra: if touched in total_extra:

View file

@ -250,7 +250,7 @@ class ElasticSyncService(BlockchainReaderService):
apply_blocking=False, apply_blocking=False,
apply_filtering=False): apply_filtering=False):
if not claim: if not claim:
self.log.warning("wat") self.log.warning("cannot sync claim %s", (claim_hash or b'').hex())
continue continue
claims[claim_hash] = claim claims[claim_hash] = claim
total_extras[claim_hash] = claim total_extras[claim_hash] = claim