Add "capacity" setting to limit the number of concurrent sessions

cmd/enduro-am-worker/main.go

@@ -139,7 +139,7 @@ func main() {
 		workerOpts := temporalsdk_worker.Options{
 			DisableWorkflowWorker:              true,
 			EnableSessionWorker:                true,
-			MaxConcurrentSessionExecutionSize:  1000,
+			MaxConcurrentSessionExecutionSize:  cfg.Capacity,
 			MaxConcurrentActivityExecutionSize: 1,
 		}
 		w := temporalsdk_worker.New(temporalClient, AmWorkerTaskQueue, workerOpts)

enduro.toml

@@ -7,6 +7,7 @@ debug = true
 debugListen = "127.0.0.1:9001"
 verbosity = 2
 useArchivematica = true
+capacity = 1
 
 [temporal]
 namespace = "default"

internal/config/config.go

@@ -27,6 +27,7 @@ type Configuration struct {
 	Debug            bool
 	DebugListen      string
 	UseArchivematica bool
+	Capacity         int
 	API              api.Config
 	Event            event.Config
 	Database         db.Config
@@ -67,6 +68,7 @@ func Read(config *Configuration, configFile string) (found bool, configFileUsed
 	v.SetDefault("api.processing", a3m.ProcessingDefault)
 	v.SetDefault("debugListen", "127.0.0.1:9001")
 	v.SetDefault("api.listen", "127.0.0.1:9000")
+	v.SetDefault("capacity", "1")
 	v.SetEnvPrefix("enduro")
 	v.SetEnvKeyReplacer(strings.NewReplacer(".", "_"))
 	v.AutomaticEnv()