Handle Job.Parallelize error in lakeCompiler.NewLakeQuery

brimdata · Oct 26, 2023 · b402680 · b402680
1 parent 92b0acd
commit b402680
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/compiler/lake.go b/compiler/lake.go
@@ -46,7 +46,9 @@ func (l *lakeCompiler) NewLakeQuery(octx *op.Context, program ast.Seq, paralleli
 		parallelism = Parallelism
 	}
 	if parallelism > 1 {
-		job.Parallelize(parallelism)
+		if err := job.Parallelize(parallelism); err != nil {
+			return nil, err
+		}
 	}
 	if err := job.Build(); err != nil {
 		return nil, err