update redis delay log

Bisonai · Jul 31, 2024 · 916d4fb · 916d4fb
1 parent 98d1dab
commit 916d4fb
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -160,13 +160,9 @@ 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]
 	diff := time.Since(data.GlobalAggregate.Timestamp)
-	if diff > 1*time.Second {
-		log.Warn().Dur("duration", diff).Str("Symbol", symbol).Str("Player", "DalCollector").Msg("processing incoming data")
-	}
-
 	diffFromPublish := time.Since(data.PublishTime)
-	if diffFromPublish > 3*time.Second {
-		log.Warn().Dur("time between Publish and processIncomingData", diffFromPublish).Str("Symbol", symbol).Str("Player", "DalCollector")
+	if diffFromPublish >= 3*time.Second || diff >= 3*time.Second {
+		log.Warn().Dur("dataDiff", diff).Dur("diffFromPublish", diffFromPublish).Str("Symbol", symbol).Str("Player", "DalCollector")
 	}
 
 	result, err := c.IncomingDataToOutgoingData(ctx, data)