Keep the cancellable context from errgroup

trufflesecurity · Jul 20, 2023 · 44a9573 · 44a9573
1 parent 3c8743c
commit 44a9573
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/engine/engine.go b/pkg/engine/engine.go
@@ -127,9 +127,10 @@ func Start(ctx context.Context, options ...EngineOption) *Engine {
 	}
 	ctx.Logger().V(2).Info("engine started", "workers", e.concurrency)
 
-	sourcesWg := &errgroup.Group{}
+	sourcesWg, egCtx := errgroup.WithContext(ctx)
 	sourcesWg.SetLimit(e.concurrency)
 	e.sourcesWg = sourcesWg
+	ctx = context.WithLogger(egCtx, ctx.Logger())
 
 	if len(e.decoders) == 0 {
 		e.decoders = decoders.DefaultDecoders()