diff --git a/core/services/llo/mercurytransmitter/server.go b/core/services/llo/mercurytransmitter/server.go index bcee6076c8b..fdd4db6e380 100644 --- a/core/services/llo/mercurytransmitter/server.go +++ b/core/services/llo/mercurytransmitter/server.go @@ -188,6 +188,11 @@ func (s *server) spawnTransmitLoop(stopCh services.StopChan, wg *sync.WaitGroup, // queue was closed return false } + if t.Report.Info.ReportFormat == llotypes.ReportFormatCapabilityTrigger { + // `capability_trigger` reports are Data Feeds product specific and aren't sent to the Mercury servers + s.pm.AsyncDelete(t.Hash()) + return true + } s.transmitThreadBusyCountInc() defer s.transmitThreadBusyCountDec()