From f32e356b2dc37313ee3249bcfa619db6ce2b6ccb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?St=C3=A9phane=20Duchesneau?=
 <stephane.duchesneau@streamingfast.io>
Date: Fri, 22 Mar 2024 00:03:11 -0400
Subject: [PATCH] fix corruption in new cached store implementation: keep
 deltas for proper ordinal lookup

---
 pipeline/exec/storeexec.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/pipeline/exec/storeexec.go b/pipeline/exec/storeexec.go
index a43604ab5..7013d4e13 100644
--- a/pipeline/exec/storeexec.go
+++ b/pipeline/exec/storeexec.go
@@ -75,7 +75,6 @@ func (e *StoreModuleExecutor) wrapDeltas() ([]byte, *pbssinternal.ModuleOutput,
 func (e *StoreModuleExecutor) toModuleOutput(data []byte) (*pbssinternal.ModuleOutput, error) {
 	if fullkvs, ok := e.outputStore.(*store.FullKV); ok {
 		deltas := fullkvs.GetDeltas()
-		fullkvs.Reset()
 
 		return &pbssinternal.ModuleOutput{
 			Data: &pbssinternal.ModuleOutput_StoreDeltas{