✨ always separate StoreResults for score + data (#1230)

This will ensure we don't have to separately batch scores (since their data size is limited) while we still get to batch up data as it's coming in. Signed-off-by: Dominik Richter <[email protected]>
mondoohq · Apr 5, 2024 · 06ec689 · 06ec689
1 parent 730da3b
commit 06ec689
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/policy/executor/internal/collector.go b/policy/executor/internal/collector.go
@@ -143,16 +143,15 @@ func (c *BufferedCollector) run() {
 
 			c.lock.Unlock()
 
-			if len(results) > 0 && !done {
+			if len(results) > 0 {
 				c.collector.Sink(results, nil, nil, false)
 				results = results[:0]
 			}
 
 			if done {
 				risks := listScoredRisks(risksIdx)
 				c.collector.updateRiskScores(c.resolvedPolicy, scores, risks)
-				c.collector.Sink(results, scores, risks, done)
-				results = results[:0]
+				c.collector.Sink(nil, scores, risks, done)
 				scores = scores[:0]
 				risksIdx = map[string]bool{}
 			}