allow other processing

julienrbrt · julienrbrt · commit 9d7601c1a53d · 2025-12-08T15:37:02.000+01:00
diff --git a/sequencers/based/sequencer.go b/sequencers/based/sequencer.go
@@ -110,7 +110,7 @@ func (s *BasedSequencer) GetNextBatch(ctx context.Context, req coresequencer.Get
 	batch := s.createBatchFromCheckpoint(req.MaxBytes)
 
 	// Update checkpoint with how many transactions we consumed
-	if daHeight > 0 {
+	if daHeight > 0 || len(batch.Transactions) > 0 {
 		s.checkpoint.TxIndex += uint64(len(batch.Transactions))
 
 		// If we've consumed all transactions from this DA epoch, move to next
diff --git a/sequencers/single/sequencer.go b/sequencers/single/sequencer.go
@@ -169,7 +169,7 @@ func (c *Sequencer) GetNextBatch(ctx context.Context, req coresequencer.GetNextB
 	}
 
 	// Update checkpoint after consuming forced inclusion transactions
-	if daHeight > 0 {
+	if daHeight > 0 || len(forcedTxs) > 0 {
 		c.checkpoint.TxIndex += uint64(len(forcedTxs))
 
 		// If we've consumed all transactions from this DA epoch, move to next

Original file line number	Diff line number	Diff line change
`@@ -169,7 +169,7 @@ func (c *Sequencer) GetNextBatch(ctx context.Context, req coresequencer.GetNextB`
`169`	`169`	`}`
`170`	`170`
`171`	`171`	`// Update checkpoint after consuming forced inclusion transactions`
`172`		`- if daHeight > 0 {`
	`172`	`+ if daHeight > 0 \|\| len(forcedTxs) > 0 {`
`173`	`173`	`c.checkpoint.TxIndex += uint64(len(forcedTxs))`
`174`	`174`
`175`	`175`	`// If we've consumed all transactions from this DA epoch, move to next`