Skip processing on closed result channel, fix panic (#215)

nautilus · Aug 21, 2024 · 634cff6 · 634cff6
1 parent 6496791
commit 634cff6
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/execute.go b/execute.go
@@ -94,7 +94,10 @@ func (executor *ParallelExecutor) Execute(ctx *ExecutionContext) (map[string]int
 		for {
 			select {
 			// we have a new result
-			case payload := <-resultCh:
+			case payload, ok := <-resultCh:
+				if !ok {
+					return
+				}
 				ctx.logger.Debug("Inserting result into ", payload.InsertionPoint)
 				ctx.logger.Debug("Result: ", payload.Result)