diff --git a/cmd/worker/main.go b/cmd/worker/main.go
index 332cd198c..d14051b9f 100644
--- a/cmd/worker/main.go
+++ b/cmd/worker/main.go
@@ -162,7 +162,7 @@ func main() {
 	w := worker.New(temporalClient, pipelineworker.TaskQueue, worker.Options{
 		EnableSessionWorker:               true,
 		WorkflowPanicPolicy:               worker.FailWorkflow,
-		MaxConcurrentSessionExecutionSize: 1000,
+		MaxConcurrentSessionExecutionSize: 50,
 	})
 
 	w.RegisterWorkflow(cw.TriggerPipelineWorkflow)