Use embedded logger

smartcontractkit · Jan 29, 2025 · 9fdeea2 · 9fdeea2
1 parent e6692eb
commit 9fdeea2
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/core/services/llo/telemetry.go b/core/services/llo/telemetry.go
@@ -75,7 +75,7 @@ func (t *telemeter) EnqueueV3PremiumLegacy(run *pipeline.Run, trrs pipeline.Task
 	if t.Service.Ready() != nil {
 		// This should never happen, telemeter should always be started BEFORE
 		// the oracle and closed AFTER it
-		t.eng.SugaredLogger.Errorw("Telemeter not ready, dropping observation", "run", run, "streamID", streamID, "opts", opts, "val", val, "err", err)
+		t.eng.Errorw("Telemeter not ready, dropping observation", "run", run, "streamID", streamID, "opts", opts, "val", val, "err", err)
 		return
 	}
 	var adapterError *eautils.AdapterError
@@ -117,7 +117,7 @@ func (t *telemeter) MakeTelemChannel(opts llo.DSOpts, size int) chan<- interface
 		// This should be performant enough with buffer of t.chch large enough
 		// that we never hit this case, however, we should NEVER block
 		// observations on telemetry even if something pathological happens.
-		t.eng.SugaredLogger.Errorw("Telemeter chch full, will not record telemetry", "seqNr", opts.SeqNr())
+		t.eng.Errorw("Telemeter chch full, will not record telemetry", "seqNr", opts.SeqNr())
 		return nil
 	}
 	return ch
@@ -183,12 +183,12 @@ func (t *telemeter) collectTelemetry(p interface{}, opts llo.DSOpts) {
 		v.DonId = t.donID
 		msg = v
 	default:
-		t.eng.SugaredLogger.Warnw("Unknown telemetry type", "type", fmt.Sprintf("%T", p))
+		t.eng.Warnw("Unknown telemetry type", "type", fmt.Sprintf("%T", p))
 		return
 	}
 	bytes, err := proto.Marshal(msg)
 	if err != nil {
-		t.eng.SugaredLogger.Warnf("protobuf marshal failed %v", err.Error())
+		t.eng.Warnf("protobuf marshal failed %v", err.Error())
 		return
 	}
 
@@ -240,15 +240,15 @@ func (t *telemeter) collectV3PremiumLegacyTelemetry(d *TelemetryPipeline) {
 		}
 		epoch, round, err := evm.SeqNrToEpochAndRound(d.opts.OutCtx().SeqNr)
 		if err != nil {
-			t.eng.SugaredLogger.Warnw("Failed to convert sequence number to epoch and round", "err", err)
+			t.eng.Warnw("Failed to convert sequence number to epoch and round", "err", err)
 		} else {
 			tea.Round = int64(round)
 			tea.Epoch = int64(epoch)
 		}
 
 		bytes, err := proto.Marshal(tea)
 		if err != nil {
-			t.eng.SugaredLogger.Warnf("protobuf marshal failed %v", err.Error())
+			t.eng.Warnf("protobuf marshal failed %v", err.Error())
 			continue
 		}