diff --git a/internal/util/pipeline/pipeline.go b/internal/util/pipeline/pipeline.go index cfc0db3e59..6e85f2d998 100644 --- a/internal/util/pipeline/pipeline.go +++ b/internal/util/pipeline/pipeline.go @@ -69,6 +69,11 @@ func (p *pipeline) Start() error { } func (p *pipeline) Close() { + for _, node := range p.nodes { + if node.Checker != nil { + node.Checker.Close() + } + } } func (p *pipeline) process() {