update redis delay log

Bisonai · Jul 31, 2024 · 3b64a35 · 3b64a35
1 parent 10f2818
commit 3b64a35
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -165,8 +165,8 @@ func (c *Collector) processIncomingData(ctx context.Context, data aggregator.Sub
 	}
 
 	diffFromPublish := time.Since(data.PublishTime)
-	if diffFromPublish > 100*time.Millisecond {
-		log.Warn().Dur("redisDelay", diffFromPublish).Str("Symbol", symbol).Str("Player", "DalCollector").Msg("redis delay over 100 millisec")
+	if diffFromPublish > 3*time.Second {
+		log.Warn().Dur("time between Publish and processIncomingData", diffFromPublish).Str("Symbol", symbol).Str("Player", "DalCollector")
 	}
 
 	result, err := c.IncomingDataToOutgoingData(ctx, data)