redis init bugfix
This commit is contained in:
@@ -108,6 +108,10 @@ async def main():
|
|||||||
runner.on_promotion.append(db_state.finalize)
|
runner.on_promotion.append(db_state.finalize)
|
||||||
if redis_state:
|
if redis_state:
|
||||||
runner.on_head_update.append(redis_state.save)
|
runner.on_head_update.append(redis_state.save)
|
||||||
|
if db:
|
||||||
|
# load initial state
|
||||||
|
log.info('initializing redis with root state')
|
||||||
|
await redis_state.save(state.root_fork, state.diffs_by_branch[state.root_branch])
|
||||||
runner.on_promotion.append(finalize_transactions)
|
runner.on_promotion.append(finalize_transactions)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user