logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-05 23:53:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: remove deletes

Browse Source
This commit is contained in:
Richard Ramos 2024-09-17 09:57:05 -04:00
parent 28ebec575e
commit c80a625423
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
2 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/storemsgcounter/execute.go
View File

@ -475,7 +475,7 @@ func (app *Application) fetchStoreNodeMessages(ctx context.Context, runId string
success := false success := false
count := 1 count := 1
for retry && count <= maxAttempts { 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) tCtx, cancel := context.WithTimeout(ctx, 1*time.Minute)
result, err = app.node.Store().Query(tCtx, store.FilterCriteria{ result, err = app.node.Store().Query(tCtx, store.FilterCriteria{

4
internal/persistence/database.go
View File

@ -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 return result, nil
} }