From 3b64a35b7c69ea5bb93ea72edb4bb5b45f1271c1 Mon Sep 17 00:00:00 2001 From: Intizar Date: Wed, 31 Jul 2024 13:31:26 +0900 Subject: [PATCH] update redis delay log --- node/pkg/dal/collector/collector.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go index 796ce2327..ea009763b 100644 --- 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)