From f9ae32f871eba194587e226670e54b8eeb74336d Mon Sep 17 00:00:00 2001 From: Danny van Kooten Date: Mon, 24 Dec 2018 12:27:21 +0100 Subject: [PATCH] empty report should have PoolEmpty: true value to prevent aggregator from re-running --- pkg/aggregator/aggregator.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/aggregator/aggregator.go b/pkg/aggregator/aggregator.go index 77f6ba18..eeca0091 100644 --- a/pkg/aggregator/aggregator.go +++ b/pkg/aggregator/aggregator.go @@ -44,6 +44,7 @@ func (agg *Aggregator) Run() Report { pageviews, err := agg.database.GetProcessablePageviews(limit) emptyReport := Report{ Processed: 0, + PoolEmpty: true, } if err != nil && err != datastore.ErrNoResults { log.Error(err)