From cedfa4ccda0a5cee9a1ccafe02472b44effc7895 Mon Sep 17 00:00:00 2001 From: Daniel Cosme Date: Tue, 4 Jun 2024 13:02:40 -0400 Subject: [PATCH] Revert "Make worker concurrent sessions configurable" This reverts commit 5bf6c7f0b1bb9b3df736a7160e31f903cec0906b. --- enduro.toml | 1 - main.go | 3 +-- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/enduro.toml b/enduro.toml index f367ec8d..a6bce9ab 100644 --- a/enduro.toml +++ b/enduro.toml @@ -85,7 +85,6 @@ disabled = true processNameMetadata = false [worker] -maxCuncurrentSessions = 1000 heartbeatThrottleInterval = "60s" [workflow] diff --git a/main.go b/main.go index abd656e4..37dd21ab 100644 --- 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: config.Worker.MaxConcurrentSessions, + MaxConcurrentSessionExecutionSize: 5000, MaxHeartbeatThrottleInterval: config.Worker.HeartbeatThrottleInterval, DefaultHeartbeatThrottleInterval: config.Worker.HeartbeatThrottleInterval, }) @@ -403,7 +403,6 @@ type configuration struct { type WorkerConfig struct { HeartbeatThrottleInterval time.Duration - MaxConcurrentSessions int } func (c configuration) Validate() error {