logging: fixed logging from parallel work queue (#1388)

Fixes #1387
This commit is contained in:
Jarek Kowalski authored and GitHub committed 2021-10-14 07:14:46 -07:00
1 parent 97c4483cc9
commit fba0956795
1 file changed
+1 -1
+1 -1
View File
@@ -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 {