diff --git a/fs/exporter/fs.go b/fs/exporter/fs.go index 3d86313..4772c39 100644 --- a/fs/exporter/fs.go +++ b/fs/exporter/fs.go @@ -87,7 +87,8 @@ type dirPerm struct { func (p *FSExporter) Export(ctx context.Context, records <-chan *connectors.Record, results chan<- *connectors.Result) (ret error) { defer close(results) - g, ctx := errgroup.WithContext(ctx) + + var g errgroup.Group g.SetLimit(p.opts.MaxConcurrency) dirPerms := make([]dirPerm, 0, 1024)