From fba0956795c9b4c62d0b9cd2bb5f536876fd5fdd Mon Sep 17 00:00:00 2001 From: Jarek Kowalski Date: Thu, 14 Oct 2021 07:14:46 -0700 Subject: [PATCH] logging: fixed logging from parallel work queue (#1388) Fixes #1387 --- internal/parallelwork/parallel_work_queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/parallelwork/parallel_work_queue.go b/internal/parallelwork/parallel_work_queue.go index 5e264d178..da23627dc 100644 --- a/internal/parallelwork/parallel_work_queue.go +++ b/internal/parallelwork/parallel_work_queue.go @@ -61,7 +61,7 @@ func (v *Queue) enqueue(ctx context.Context, front bool, callback CallbackFunc) func (v *Queue) Process(ctx context.Context, workers int) error { defer v.reportProgress(ctx) - eg, ctx := errgroup.WithContext(context.Background()) + eg, ctx := errgroup.WithContext(ctx) for i := 0; i < workers; i++ { eg.Go(func() error {