diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go
index 7b6e27b..1a4ec68 100644
--- a/cmd/storemsgcounter/execute.go
+++ b/cmd/storemsgcounter/execute.go
@@ -475,7 +475,7 @@ func (app *Application) fetchStoreNodeMessages(ctx context.Context, runId string
 	success := false
 	count := 1
 	for retry && count <= maxAttempts {
-		queryLogger.Info("retrieving message history for topic!", zap.Int("attempt", count))
+		queryLogger.Info("retrieving message history for topic", zap.Int("attempt", count))
 
 		tCtx, cancel := context.WithTimeout(ctx, 1*time.Minute)
 		result, err = app.node.Store().Query(tCtx, store.FilterCriteria{
diff --git a/internal/persistence/database.go b/internal/persistence/database.go
index ebaacc8..8fa9e07 100644
--- a/internal/persistence/database.go
+++ b/internal/persistence/database.go
@@ -121,10 +121,6 @@ func NewDBStore(clusterID uint, fleetName string, log *zap.Logger, options ...DB
 		}
 	}
 
-	result.db.Exec("DELETE FROM synctopicstatus WHERE clusterid = 16 AND fleet IN( 'waku-sandbox', 'waku-test', 'status.stagging') ")
-	result.db.Exec("DELETE FROM missingmessages WHERE clusterid = 16 AND fleet IN( 'waku-sandbox', 'waku-test', 'status.stagging') ")
-	result.db.Exec("DELETE FROM storenodeunavailable WHERE fleet = 'status.stagging'")
-
 	return result, nil
 }