diff --git a/state/execution.go b/state/execution.go index 9b4e74382ab..62b05be3455 100644 --- a/state/execution.go +++ b/state/execution.go @@ -315,9 +315,11 @@ func (blockExec *BlockExecutor) applyBlock(state State, blockID types.BlockID, b } } - // Events are fired after everything else. - // NOTE: if we crash between Commit and Save, events wont be fired during replay - fireEvents(blockExec.logger, blockExec.eventBus, block, blockID, abciResponse, validatorUpdates) + if _, ok := blockExec.eventBus.(types.NopEventBus); !ok { + // Events are fired after everything else. + // NOTE: if we crash between Commit and Save, events wont be fired during replay + go fireEvents(blockExec.logger, blockExec.eventBus, block, blockID, abciResponse, validatorUpdates) + } return state, nil }