Pass "true" for continueOnError from WorkerPoolIgnoreError. (#1117)

apigee · Mar 22, 2023 · ddc4fbb · ddc4fbb
1 parent 2e9fc58
commit ddc4fbb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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")