fix noopHandler to never forward StepStalled blocks

streamingfast · Jul 16, 2024 · fa4afa9 · fa4afa9
1 parent 01a9eea
commit fa4afa9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/service/noopHandler.go b/service/noopHandler.go
@@ -22,6 +22,13 @@ func (n NoopHandler) ProcessBlock(blk *pbbstream.Block, obj interface{}) (err er
 	clock := pipeline.BlockToClock(blk)
 
 	step := obj.(bstream.Stepable).Step()
+	switch step {
+	case bstream.StepIrreversible,
+		bstream.StepNewIrreversible,
+		bstream.StepNew:
+	default:
+		return nil
+	}
 
 	cursor := &bstream.Cursor{
 		Step:      step,