vrfv2: Add request id to logs in runPipelines (#13172)

smartcontractkit · Jun 25, 2024 · f38886c · f38886c
1 parent 76bdd9d
commit f38886c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)
 	}