From ddc4fbb22c8102e933b5ef93af795b44b2c1f326 Mon Sep 17 00:00:00 2001 From: Tim Burks Date: Wed, 22 Mar 2023 08:30:51 -0700 Subject: [PATCH] Pass "true" for continueOnError from WorkerPoolIgnoreError. (#1117) --- cmd/registry/tasks/tasks.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/registry/tasks/tasks.go b/cmd/registry/tasks/tasks.go index 67a364047..c12c23cb9 100644 --- a/cmd/registry/tasks/tasks.go +++ b/cmd/registry/tasks/tasks.go @@ -86,7 +86,7 @@ func WorkerPool(ctx context.Context, n int, continueOnError bool) (chan<- Task, // returns a wait function that captures and logs the error at Error level. This // is convenient for defer. func WorkerPoolIgnoreError(ctx context.Context, n int) (chan<- Task, func()) { - wp, w := WorkerPool(ctx, n, false) + wp, w := WorkerPool(ctx, n, true) wait := func() { if err := w(); err != nil { log.FromContext(ctx).WithError(err).Errorf("unhandled WorkerPool error")