logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-04 07:03:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: logs

Browse Source
This commit is contained in:
Richard Ramos 2024-05-30 15:46:40 -04:00
parent fceccf94b7
commit b82c5c1a3a
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/storemsgcounter/execute.go
View File

@ -292,7 +292,7 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn
queryLbl: queryLbl:
for i := 0; i < maxAttempts; i++ { for i := 0; i < maxAttempts; i++ {
logger.Info("retrieving message history for topic!", zap.Stringer("storenode", node), zap.Int64("from", startTime.UnixNano()), zap.Int64("to", endTime.UnixNano()), zap.Int("attempt", i)) logger.Info("retrieving message history for topic!", zap.Stringer("storenode", node.ID), zap.Int64("startTime", startTime.UnixNano()), zap.Int64("endTime", endTime.UnixNano()), zap.Int("attempt", i))
tCtx, cancel := context.WithTimeout(ctx, 1*time.Minute) tCtx, cancel := context.WithTimeout(ctx, 1*time.Minute)
result, err = wakuNode.Store().Query(tCtx, store.FilterCriteria{ result, err = wakuNode.Store().Query(tCtx, store.FilterCriteria{