add log on undo

streamingfast · Feb 19, 2024 · b38cd28 · b38cd28
1 parent 88cc3d5
commit b38cd28
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sinker/sinker.go b/sinker/sinker.go
@@ -129,6 +129,8 @@ func (s *KVSinker) handleBlockScopedData(ctx context.Context, data *pbsubstreams
 
 func (s *KVSinker) handleBlockUndoSignal(ctx context.Context, data *pbsubstreamsrpc.BlockUndoSignal, cursor *sink.Cursor) error {
 
+	s.logger.Info("handling undo signal", zap.Uint64("block_num", data.LastValidBlock.GetNumber()))
+
 	err := s.operationDB.HandleBlockUndo(ctx, data.LastValidBlock.GetNumber())
 	if err != nil {
 		return fmt.Errorf("handling undo signal: %w", err)