clear es attributes during initial sync
This commit is contained in:
parent
8d72142390
commit
cdef8b4852
1 changed files with 5 additions and 0 deletions
|
@ -345,6 +345,11 @@ class BlockProcessor:
|
||||||
"applying extended claim expiration fork on claims accepted by, %i", self.height
|
"applying extended claim expiration fork on claims accepted by, %i", self.height
|
||||||
)
|
)
|
||||||
await self.run_in_thread_with_lock(self.db.apply_expiration_extension_fork)
|
await self.run_in_thread_with_lock(self.db.apply_expiration_extension_fork)
|
||||||
|
if self.db.first_sync:
|
||||||
|
self.db.search_index.clear_caches()
|
||||||
|
self.touched_claims_to_send_es.clear()
|
||||||
|
self.removed_claims_to_send_es.clear()
|
||||||
|
self.activation_info_to_send_es.clear()
|
||||||
# TODO: we shouldnt wait on the search index updating before advancing to the next block
|
# TODO: we shouldnt wait on the search index updating before advancing to the next block
|
||||||
if not self.db.first_sync:
|
if not self.db.first_sync:
|
||||||
await self.db.reload_blocking_filtering_streams()
|
await self.db.reload_blocking_filtering_streams()
|
||||||
|
|
Loading…
Reference in a new issue