LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

claim producer fix

Browse source
This commit is contained in:
Jack Robison 2021-10-13 15:24:14 -04:00
parent 3dc3792478
commit 82de92c324
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lbry/wallet/server/leveldb.py
View file

@ -701,19 +701,19 @@ class LevelDB:
def produce_claims(claims): def produce_claims(claims):
batch = [] batch = []
results = [] _results = []
for claim_hash in claims: for claim_hash in claims:
if claim_hash not in self.claim_to_txo: if claim_hash not in self.claim_to_txo:
self.logger.warning("can't sync non existent claim to ES: %s", claim_hash.hex()) self.logger.warning("can't sync non existent claim to ES: %s", claim_hash.hex())
return continue
name = self.claim_to_txo[claim_hash].normalized_name name = self.claim_to_txo[claim_hash].normalized_name
if not self.prefix_db.claim_takeover.get(name): if not self.prefix_db.claim_takeover.get(name):
self.logger.warning("can't sync non existent claim to ES: %s", claim_hash.hex()) self.logger.warning("can't sync non existent claim to ES: %s", claim_hash.hex())
return continue
claim_txo = self.claim_to_txo.get(claim_hash) claim_txo = self.claim_to_txo.get(claim_hash)
if not claim_txo: if not claim_txo:
return continue
activation = self.get_activation(claim_txo.tx_num, claim_txo.position) activation = self.get_activation(claim_txo.tx_num, claim_txo.position)
claim = self._prepare_resolve_result( claim = self._prepare_resolve_result(
claim_txo.tx_num, claim_txo.position, claim_hash, claim_txo.name, claim_txo.root_tx_num, claim_txo.tx_num, claim_txo.position, claim_hash, claim_txo.name, claim_txo.root_tx_num,
@ -725,10 +725,10 @@ class LevelDB:
batch.sort(key=lambda x: x.tx_hash) batch.sort(key=lambda x: x.tx_hash)
for claim in batch: for claim in batch:
meta = self._prepare_claim_metadata(claim.claim_hash, claim) _meta = self._prepare_claim_metadata(claim.claim_hash, claim)
if meta: if _meta:
results.append(meta) _results.append(_meta)
return results return _results
if claim_hashes: if claim_hashes:
results = await loop.run_in_executor(None, produce_claims, claim_hashes) results = await loop.run_in_executor(None, produce_claims, claim_hashes)