prevent scanning all undos entry ...

streamingfast · Apr 4, 2024 · 6ca06c8 · 6ca06c8
1 parent 0a14f7e
commit 6ca06c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/db/db.go b/db/db.go
@@ -140,7 +140,7 @@ func (db *OperationDB) Flush(ctx context.Context, cursor *sink.Cursor) (count in
 func (db *OperationDB) PurgeUndoOperations(ctx context.Context, finalBlockHeight uint64) error {
 	keys := make([][]byte, 0)
 
-	scanOutput := db.store.Scan(ctx, undoKey(finalBlockHeight), undoKey(0), 0)
+	scanOutput := db.store.Scan(ctx, undoKey(finalBlockHeight), undoKey(finalBlockHeight-1000), 0)
 
 	if scanOutput.Err() != nil {
 		return fmt.Errorf("scanning undo operations for block %d: %w", finalBlockHeight, scanOutput.Err())