From 9771b46f6da2ef70dda0670c34df31590af7b883 Mon Sep 17 00:00:00 2001 From: nick <nick@bisonai.com> Date: Tue, 10 Dec 2024 17:00:03 +0900 Subject: [PATCH] feat: add log --- node/pkg/dal/collector/collector.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go index 9112956e0..57360184d 100644 --- a/node/pkg/dal/collector/collector.go +++ b/node/pkg/dal/collector/collector.go @@ -214,6 +214,8 @@ func (c *Collector) processIncomingData(ctx context.Context, data *aggregator.Su case <-ctx.Done(): return default: + log.Debug().Any("data", data).Str("Player", "DalCollector").Msg("received data") + valid := c.compareAndSwapLatestTimestamp(data) if !valid { log.Debug().Str("Player", "DalCollector").Str("Symbol", data.Symbol).Msg("old data recieved")