Start with half the max workers to speed up startup

stanfordio · Oct 20, 2024 · dcc2597 · dcc2597
1 parent 42c87fe
commit dcc2597
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/stream/stream.go b/pkg/stream/stream.go
@@ -38,8 +38,9 @@ func (s *Stream) BeginStreaming(ctx context.Context, workerCount int) error {
 	defer cancel()
 
 	scalingSettings := autoscaling.DefaultAutoscaleSettings()
+	// Start with half the max workers
+	scalingSettings.Concurrency = workerCount / 2
 	scalingSettings.MaxConcurrency = workerCount
-	scalingSettings.AutoscaleFrequency = time.Second
 
 	pool := autoscaling.NewScheduler(scalingSettings, s.SocketURL.Host, s.HandleStreamEvent)