Make worker concurrent sessions configurable

artefactual-labs · Jun 4, 2024 · 5bf6c7f · 5bf6c7f
1 parent 4ca9fb0
commit 5bf6c7f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/enduro.toml b/enduro.toml
@@ -85,6 +85,7 @@ disabled = true
 processNameMetadata = false
 
 [worker]
+maxCuncurrentSessions = 1000
 heartbeatThrottleInterval = "60s"
 
 [workflow]

diff --git a/main.go b/main.go
@@ -254,7 +254,7 @@ func main() {
 		done := make(chan struct{})
 		w := temporalsdk_worker.New(temporalClient, config.Temporal.TaskQueue, temporalsdk_worker.Options{
 			EnableSessionWorker:               true,
-			MaxConcurrentSessionExecutionSize: 5000,
+			MaxConcurrentSessionExecutionSize: config.Worker.MaxConcurrentSessions,
 			MaxHeartbeatThrottleInterval:      config.Worker.HeartbeatThrottleInterval,
 			DefaultHeartbeatThrottleInterval:  config.Worker.HeartbeatThrottleInterval,
 		})
@@ -403,6 +403,7 @@ type configuration struct {
 
 type WorkerConfig struct {
 	HeartbeatThrottleInterval time.Duration
+	MaxConcurrentSessions     int
 }
 
 func (c configuration) Validate() error {