diff --git a/pkg/lokiunifi/loki.go b/pkg/lokiunifi/loki.go index 78ece956..b97f2997 100644 --- a/pkg/lokiunifi/loki.go +++ b/pkg/lokiunifi/loki.go @@ -180,6 +180,11 @@ func (l *Loki) ProcessEvents(report *Report, events *poller.Events) error { } logs := report.ProcessEventLogs(events) + if len(logs.Streams) == 0 { + l.LogDebugf("No new events to send to Loki.") + return nil + } + if err := l.client.Post(logs); err != nil { return fmt.Errorf("sending to Loki failed: %w", err) }