diff --git a/go/worker/compute/executor/committee/hooks.go b/go/worker/compute/executor/committee/hooks.go index 017f67e4463..601115a3cda 100644 --- a/go/worker/compute/executor/committee/hooks.go +++ b/go/worker/compute/executor/committee/hooks.go @@ -1,8 +1,6 @@ package committee import ( - "context" - "github.com/oasisprotocol/oasis-core/go/common/crash" runtime "github.com/oasisprotocol/oasis-core/go/runtime/api" "github.com/oasisprotocol/oasis-core/go/worker/common/committee" @@ -35,12 +33,6 @@ func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo) { // HandleNewBlockLocked implements NodeHooks. // Guarded by n.commonNode.CrossNode. func (n *Node) HandleNewBlockLocked(bi *runtime.BlockInfo) { - // Drop blocks if the worker falls behind. - select { - case <-n.blockInfoCh: - default: - } - - // Non-blocking send. + // Don't skip any blocks, as the round worker must finalize the final round. n.blockInfoCh <- bi }