From 640b5b0ea930f95566ef7dcce0e84324b5d9e913 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Wed, 1 Apr 2020 13:52:30 -0400 Subject: [PATCH] delete_claims_above_height with thread lock --- lbry/wallet/server/block_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lbry/wallet/server/block_processor.py b/lbry/wallet/server/block_processor.py index d6cdd7b74..44eba7d1a 100644 --- a/lbry/wallet/server/block_processor.py +++ b/lbry/wallet/server/block_processor.py @@ -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(flush_backup) 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) REORG_COUNT.inc()