From 60aed954d2745488c19ada24816c2510fbc9133b Mon Sep 17 00:00:00 2001 From: "Chang, Hui-Tang" Date: Thu, 12 Sep 2024 11:01:35 +0800 Subject: [PATCH] chore: adjust MaxConcurrentSessionExecutionSize --- cmd/worker/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)