forked from LBRYCommunity/lbry-sdk
opening dbs can raise too
This commit is contained in:
parent
e77acde005
commit
7a044f9f78
1 changed files with 4 additions and 1 deletions
|
@ -645,12 +645,15 @@ class BlockProcessor:
|
||||||
could be lost.
|
could be lost.
|
||||||
"""
|
"""
|
||||||
self._caught_up_event = caught_up_event
|
self._caught_up_event = caught_up_event
|
||||||
await self._first_open_dbs()
|
|
||||||
try:
|
try:
|
||||||
|
await self._first_open_dbs()
|
||||||
await asyncio.wait([
|
await asyncio.wait([
|
||||||
self.prefetcher.main_loop(self.height),
|
self.prefetcher.main_loop(self.height),
|
||||||
self._process_prefetched_blocks()
|
self._process_prefetched_blocks()
|
||||||
])
|
])
|
||||||
|
except:
|
||||||
|
self.logger.exception("Block processing failed!")
|
||||||
|
raise
|
||||||
finally:
|
finally:
|
||||||
# Shut down block processing
|
# Shut down block processing
|
||||||
self.logger.info('flushing to DB for a clean shutdown...')
|
self.logger.info('flushing to DB for a clean shutdown...')
|
||||||
|
|
Loading…
Reference in a new issue