fix tier1 not deleting partial stores in some conditions

streamingfast · Dec 21, 2023 · a355c50 · a355c50
1 parent ddf7386
commit a355c50
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/orchestrator/stage/squash.go b/orchestrator/stage/squash.go
@@ -84,13 +84,10 @@ func (s *Stages) singleSquash(stage *Stage, modState *ModuleState, mergeUnit Uni
 	modState.lastBlockInStore = rng.ExclusiveEndBlock
 	metrics.mergeEnd = time.Now()
 
-	// Delete partial store
-	if reqctx.Details(s.ctx).ProductionMode || segmentEndsOnInterval { /* FIXME: compute this elsewhere? */
-		s.logger.Info("deleting store", zap.Stringer("store", partialKV))
-		stage.asyncWork.Go(func() error {
-			return partialKV.DeleteStore(s.ctx, partialFile)
-		})
-	}
+	s.logger.Info("deleting partial store", zap.Stringer("store", partialKV))
+	stage.asyncWork.Go(func() error {
+		return partialKV.DeleteStore(s.ctx, partialFile)
+	})
 
 	// Flush full store
 	if segmentEndsOnInterval {