mirror of
https://github.com/LBRYFoundation/lbry-sdk.git
synced 2025-09-15 15:09:48 +00:00
delete_claims_above_height with thread lock
This commit is contained in:
parent
e4fb2f4680
commit
640b5b0ea9
1 changed files with 1 additions and 1 deletions
|
@ -253,7 +253,7 @@ class BlockProcessor:
|
||||||
await self.run_in_thread_with_lock(self.backup_blocks, raw_blocks)
|
await self.run_in_thread_with_lock(self.backup_blocks, raw_blocks)
|
||||||
await self.run_in_thread_with_lock(flush_backup)
|
await self.run_in_thread_with_lock(flush_backup)
|
||||||
last -= len(raw_blocks)
|
last -= len(raw_blocks)
|
||||||
self.db.sql.delete_claims_above_height(self.height)
|
await self.run_in_thread_with_lock(self.db.sql.delete_claims_above_height, self.height)
|
||||||
await self.prefetcher.reset_height(self.height)
|
await self.prefetcher.reset_height(self.height)
|
||||||
REORG_COUNT.inc()
|
REORG_COUNT.inc()
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue