From f411ab4fcd5cb788f3ba59e8ca188779d58e7395 Mon Sep 17 00:00:00 2001 From: registergoofy <70151212+registergoofy@users.noreply.github.com> Date: Thu, 3 Dec 2020 17:34:57 +0100 Subject: [PATCH] Fix a crash (#503) * fix a crash --- pkg/leakybucket/overflows.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/leakybucket/overflows.go b/pkg/leakybucket/overflows.go index cb74f8810..c8cdd596c 100644 --- a/pkg/leakybucket/overflows.go +++ b/pkg/leakybucket/overflows.go @@ -49,6 +49,8 @@ func SourceFromEvent(evt types.Event, leaky *Leaky) (map[string]models.Source, e *src.Value = v.Range *src.Scope = leaky.scopeType.Scope srcs[*src.Value] = src + } else { + log.Warningf("bucket %s requires scope Range, but none was provided. It seems that the %s wasn't enriched to include its range.", leaky.Name, *v.Value) } } else { log.Warningf("bucket %s requires scope Range, but can't extrapolate from %s (%s)", @@ -277,7 +279,10 @@ func NewAlert(leaky *Leaky, queue *Queue) (types.RuntimeAlert, error) { runtimeAlert.APIAlerts = append(runtimeAlert.APIAlerts, newApiAlert) } - runtimeAlert.Alert = &runtimeAlert.APIAlerts[0] + if len(runtimeAlert.APIAlerts) > 0 { + runtimeAlert.Alert = &runtimeAlert.APIAlerts[0] + } + if leaky.Reprocess { runtimeAlert.Reprocess = true }