bugfix: wait in dom for the pendingEtx to be generated by the sub

core/core.go

@@ -68,6 +68,7 @@ func (c *Core) InsertChain(blocks types.Blocks) (int, error) {
 			if err != nil {
 				if err == consensus.ErrFutureBlock ||
 					err.Error() == ErrBodyNotFound.Error() ||
+					err.Error() == ErrPendingEtxNotFound.Error() ||
 					err.Error() == consensus.ErrPrunedAncestor.Error() ||
 					err.Error() == consensus.ErrUnknownAncestor.Error() ||
 					err.Error() == ErrSubNotSyncedToDom.Error() ||

core/error.go

@@ -43,9 +43,12 @@ var (
 
 	// ErrBadSubManifest is returned when a block's subordinate manifest does not match the subordinate manifest hash
 	ErrBadSubManifest = errors.New("subordinate manifest is incorrect")
-	
+
 	//ErrAddedFutureCache is returned when a block could not be appended yet and has been added to the future cache to retry later
 	ErrAddedFutureCache = errors.New("block was added to future cache")
+
+	//ErrPendingEtxNotFound is returned when pendingEtxs cannot be found for a hash given in the submanifest
+	ErrPendingEtxNotFound = errors.New("pending etx not found")
 )
 
 // List of evm-call-message pre-checking errors. All state transition messages will

core/slice.go

@@ -292,7 +292,8 @@ func (sl *Slice) CollectSubRollups(b *types.Block) ([]types.Transactions, error)
 			} else if res := rawdb.ReadPendingEtxs(sl.sliceDb, hash); res != nil {
 				pendingEtxs = res
 			} else {
-				return nil, fmt.Errorf("unable to find pending etxs for hash in manifest, hash: %s", hash.String())
+				log.Warn("unable to find pending etxs for hash in manifest", "hash:", hash.String())
+				return nil, ErrPendingEtxNotFound
 			}
 			for ctx := nodeCtx; ctx < common.HierarchyDepth; ctx++ {
 				subRollups[ctx] = append(subRollups[ctx], pendingEtxs[ctx]...)