bugfix
This commit is contained in:
@@ -72,6 +72,8 @@ async def main():
|
|||||||
if memcache:
|
if memcache:
|
||||||
await memcache.connect()
|
await memcache.connect()
|
||||||
redis_state = RedisState(BlockData.by_opt('redis'))
|
redis_state = RedisState(BlockData.by_opt('redis'))
|
||||||
|
else:
|
||||||
|
log.debug('No memcache')
|
||||||
db.connect()
|
db.connect()
|
||||||
if db:
|
if db:
|
||||||
db_state = DbState(BlockData.by_opt('db'))
|
db_state = DbState(BlockData.by_opt('db'))
|
||||||
@@ -79,7 +81,8 @@ async def main():
|
|||||||
state = await db_state.load()
|
state = await db_state.load()
|
||||||
if state is None:
|
if state is None:
|
||||||
log.info('no state in database')
|
log.info('no state in database')
|
||||||
await redis_state.clear()
|
if redis_state:
|
||||||
|
await redis_state.clear()
|
||||||
else:
|
else:
|
||||||
current_blockstate.set(state)
|
current_blockstate.set(state)
|
||||||
current_fork.set(state.root_fork)
|
current_fork.set(state.root_fork)
|
||||||
|
|||||||
Reference in New Issue
Block a user