From c80a6254238dcdb9dcc66197bce2cb4baceac352 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Tue, 17 Sep 2024 09:57:05 -0400 Subject: [PATCH] chore: remove deletes --- cmd/storemsgcounter/execute.go | 2 +- internal/persistence/database.go | 4 ---- 2 files changed, 1 insertion(+), 5 deletions(-) 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 }