Merge pull request #3987 from oasisprotocol/kostko/feature/executor-s…

…ched-epoch

.changelog/3987.feature.md

@@ -0,0 +1 @@
+go/worker/compute: Propose block on new epoch

go/oasis-node/node_test.go

@@ -523,14 +523,14 @@ func testStorageClientWithNode(t *testing.T, node *testNode) {
 	require.NoError(t, err, "NewStatic")
 
 	// Determine the current round. This is required so that we can commit into
-	// storage at the next (non-finalized) round.
+	// storage at some higher (non-finalized) round.
 	blk, err := node.Consensus.RootHash().GetLatestBlock(ctx, &roothash.RuntimeRequest{
 		RuntimeID: testRuntimeID,
 		Height:    consensusAPI.HeightLatest,
 	})
 	require.NoError(t, err, "GetLatestBlock")
 
-	storageTests.StorageImplementationTests(t, localBackend, client, testRuntimeID, blk.Header.Round+1)
+	storageTests.StorageImplementationTests(t, localBackend, client, testRuntimeID, blk.Header.Round+1000)
 }
 
 func testStorageClientWithoutNode(t *testing.T, node *testNode) {

go/worker/compute/executor/committee/node.go

@@ -807,6 +807,8 @@ func (n *Node) handleScheduleBatch(force bool) {
 		// We have runtime message results (and batch timeout expired), schedule batch.
 	case rtState.LastNormalRound == rtState.GenesisBlock.Header.Round:
 		// This is the runtime genesis, schedule batch.
+	case force && rtState.LastNormalHeight < epoch.GetGroupVersion():
+		// No block in this epoch processed by runtime yet, schedule batch.
 	default:
 		// No need to schedule a batch.
 		return