From a355c5063d0c0c0d32cc5c0a19311a82f2736adc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?St=C3=A9phane=20Duchesneau?=
 <stephane.duchesneau@streamingfast.io>
Date: Thu, 21 Dec 2023 15:07:39 -0500
Subject: [PATCH] fix tier1 not deleting partial stores in some conditions

---
 orchestrator/stage/squash.go | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/orchestrator/stage/squash.go b/orchestrator/stage/squash.go
index bbadb9034..4d38b76b0 100644
--- 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 {