udpate dal collector info logs to warn

Bisonai · Jul 30, 2024 · 8be5161 · 8be5161
1 parent 41d41fd
commit 8be5161
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -159,15 +159,21 @@ func (c *Collector) receiveEach(ctx context.Context, configId int32) error {
 
 func (c *Collector) processIncomingData(ctx context.Context, data aggregator.SubmissionData) {
 	symbol := c.Symbols[data.GlobalAggregate.ConfigID]
-	log.Info().Msgf(
-		"%s: %.2f seconds had passed when data is received",
-		symbol,
-		time.Since(data.GlobalAggregate.Timestamp).Seconds(),
-	)
+	diff := time.Since(data.GlobalAggregate.Timestamp).Seconds()
+	if diff > 3 {
+		log.Warn().Msgf(
+			"%s: %.2f seconds had passed when data is received",
+			symbol,
+			diff,
+		)
+	}
 
 	start := time.Now()
 	result, err := c.IncomingDataToOutgoingData(ctx, data)
-	log.Info().Msgf("%s took %.2f seconds to process", symbol, time.Since(start).Seconds())
+	diff = time.Since(start).Seconds()
+	if diff > 3 {
+		log.Warn().Msgf("%s took %.2f seconds to process", symbol)
+	}
 
 	if err != nil {
 		log.Error().Err(err).Str("Player", "DalCollector").Msg("failed to convert incoming data to outgoing data")