Fix decision log hang

..by breaking out of loop if context is cancelled. Fixes open-policy-agent#2792 Signed-off-by: Anders Eknert <anders.eknert@bisnode.com>
ashutosh-narkar · Oct 19, 2020 · deb61d0 · deb61d0
1 parent 9f4aed2
commit deb61d0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/logs/plugin.go b/plugins/logs/plugin.go
@@ -420,7 +420,7 @@ func (p *Plugin) flushDecisions(ctx context.Context, cancel context.CancelFunc)
 	defer cancel()
 
 	go func(ctx context.Context, cancel context.CancelFunc) {
-		for {
+		for ctx.Err() == nil {
 			ok, err := p.oneShot(ctx)
 			if err != nil {
 				p.logError("%v.", err)