diff --git a/internal/state/execution.go b/internal/state/execution.go index c913b48a4..fa125ccbb 100644 --- a/internal/state/execution.go +++ b/internal/state/execution.go @@ -128,7 +128,6 @@ func (blockExec *BlockExecutor) CreateProposalBlock( MaxTxBytes: maxDataBytes, }, ) - if err != nil { // The App MUST ensure that only valid (and hence 'processable') transactions // enter the mempool. Hence, at this point, we can't have any non-processable @@ -148,6 +147,11 @@ func (blockExec *BlockExecutor) CreateProposalBlock( blockExec.logger.Debug("error removing transaction from the mempool", "error", err) } } + for _, rtx := range rpp.AddedTxs() { + if err := blockExec.mempool.CheckTx(ctx, rtx.Tx, nil, mempool.TxInfo{}); err != nil { + blockExec.logger.Debug("error removing transaction from the mempool", "error", err) + } + } return state.MakeBlock(height, types.TxRecordsToTxs(rpp.IncludedTxs()), commit, evidence, proposerAddr) }