From f38886ce95b8a4a5106871cfa3fc4fe73d46c80c Mon Sep 17 00:00:00 2001 From: Lee Yik Jiun Date: Tue, 25 Jun 2024 11:25:13 +0800 Subject: [PATCH] vrfv2: Add request id to logs in runPipelines (#13172) --- core/services/vrf/v2/listener_v2_log_processor.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/services/vrf/v2/listener_v2_log_processor.go b/core/services/vrf/v2/listener_v2_log_processor.go index 145e72ed2bc..9408768d4de 100644 --- a/core/services/vrf/v2/listener_v2_log_processor.go +++ b/core/services/vrf/v2/listener_v2_log_processor.go @@ -1049,7 +1049,8 @@ func (lsn *listenerV2) runPipelines( wg.Add(1) go func(i int, req pendingRequest) { defer wg.Done() - results[i] = lsn.simulateFulfillment(ctx, maxGasPriceWei, req, l) + ll := l.With("reqID", req.req.RequestID().String()) + results[i] = lsn.simulateFulfillment(ctx, maxGasPriceWei, req, ll) }(i, req) } wg.Wait() @@ -1103,7 +1104,6 @@ func (lsn *listenerV2) simulateFulfillment( if err != nil { // not critical, just log and continue lg.Warnw("unable to estimate funds needed for request, continuing anyway", - "reqID", req.req.RequestID(), "err", err) res.fundsNeeded = big.NewInt(0) }