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)