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

fix: log level

Browse Source
This commit is contained in:
Richard Ramos 2024-05-29 22:25:53 -04:00
parent 584fd8f2c3
commit 7ebfe40900
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/storemsgcounter/execute.go
View File

@ -237,7 +237,7 @@ func verifyHistory(ctx context.Context, storenodes []peer.AddrInfo, wakuNode *no
}
if len(unknownIn) != 0 {
logger.Debug("message with unknown state identified", zap.Stringer("hash", msgHash), zap.String("pubsubTopic", msgAttr[msgHash].PubsubTopic), zap.Int("num_nodes", len(missingIn)))
logger.Info("message with unknown state identified", zap.Stringer("hash", msgHash), zap.String("pubsubTopic", msgAttr[msgHash].PubsubTopic), zap.Int("num_nodes", len(missingIn)))
err = dbStore.RecordMessage(runId, tx, msgHash, options.ClusterID, msgAttr[msgHash].PubsubTopic, msgAttr[msgHash].Timestamp, unknownIn, "unknown")
if err != nil {
return err
@ -289,7 +289,7 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn
storeNodeFailure = true
time.Sleep(2 * time.Second)
} else {
logger.Debug("messages available?", zap.Int("len", len(result.Messages())))
logger.Info("messages available?", zap.Int("len", len(result.Messages())))
storeNodeFailure = false
break queryLbl
}

2
cmd/storemsgcounter/main.go
View File

@ -11,7 +11,7 @@ var options Options
func main() {
// Defaults
options.LogLevel = "DEBUG"
options.LogLevel = "INFO"
options.LogEncoding = "console"
app := &cli.App{