diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go index 548dd8d..d11fe70 100644 --- a/cmd/storemsgcounter/execute.go +++ b/cmd/storemsgcounter/execute.go @@ -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 } diff --git a/cmd/storemsgcounter/main.go b/cmd/storemsgcounter/main.go index 3fa18e0..88efbed 100644 --- a/cmd/storemsgcounter/main.go +++ b/cmd/storemsgcounter/main.go @@ -11,7 +11,7 @@ var options Options func main() { // Defaults - options.LogLevel = "DEBUG" + options.LogLevel = "INFO" options.LogEncoding = "console" app := &cli.App{