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) }