add new 'cachingstore' to fix the wrong outputdeltas saved on stores

streamingfast · Mar 19, 2024 · 8dbda9c · 8dbda9c
1 parent 678e9c8
commit 8dbda9c
Show file tree

Hide file tree

Showing 9 changed files with 697 additions and 32 deletions.
diff --git a/orchestrator/stage/squash.go b/orchestrator/stage/squash.go
@@ -54,7 +54,6 @@ func (s *Stages) multiSquash(stage *Stage, mergeUnit Unit) error {
 // We keep the cache of the latest FullKV store, to speed up things
 // if they are linear
 func (s *Stages) singleSquash(stage *Stage, modState *StoreModuleState, mergeUnit Unit) error {
-	fmt.Println("SQUASHING", modState.name)
 	metrics := mergeMetrics{}
 	metrics.start = time.Now()
 

diff --git a/pb/last_generate.txt b/pb/last_generate.txt
@@ -1,2 +1,2 @@
-generate.sh - Thu 14 Mar 2024 10:02:19 EDT - arnaudberger
-streamingfast/proto revision: 2999cd42d71a82c4adf739557f9520f0609f7b10
+generate.sh - Tue Mar 19 09:09:54 EDT 2024 - stepd
+streamingfast/proto revision: fde3637cef38103a68301d0ca19b3f2af9b6079b
diff --git a/pb/sf/substreams/intern/v2/deltas.pb.go b/pb/sf/substreams/intern/v2/deltas.pb.go