Increase buffer size (#130)

nautilus · Mar 16, 2021 · c001b08 · c001b08
1 parent 1078926
commit c001b08
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plan.go b/plan.go
@@ -143,7 +143,7 @@ func (p *MinQueriesPlanner) generatePlans(ctx *PlanningContext, query *ast.Query
 		plans = append(plans, plan)
 
 		// a channel to register new steps
-		stepCh := make(chan *newQueryPlanStepPayload, 10)
+		stepCh := make(chan *newQueryPlanStepPayload, 50)
 
 		// a chan to get errors
 		errCh := make(chan error)