add log to validate steps

streamingfast · Feb 8, 2024 · 7b4e949 · 7b4e949
1 parent 6eac855
commit 7b4e949
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/db/db.go b/db/db.go
@@ -79,6 +79,7 @@ func (db *OperationDB) AddOperation(op *pbkv.KVOperation) {
 }
 func (db *OperationDB) HandleOperations(ctx context.Context, blockNumber uint64, finalBlockHeight uint64, step bstream.StepType, kvOps *pbkv.KVOperations) error {
 	if step == bstream.StepNew {
+		db.logger.Info("handling undos", zap.Uint64("block_number", blockNumber), zap.Int("step", int(step)))
 		err := db.PurgeUndoOperations(ctx, finalBlockHeight)
 		if err != nil {
 			return fmt.Errorf("deleting LIB undo operations: %w", err)