diff --git a/docs/09-Configuration reference/01-Settings.md b/docs/09-Configuration reference/01-Settings.md index 9009ae8c..f1b732b2 100644 --- a/docs/09-Configuration reference/01-Settings.md +++ b/docs/09-Configuration reference/01-Settings.md @@ -29,6 +29,7 @@ While we have some basic types (string, number, bool ...), we also have some com | ledger.experimental-numscript-interpreter | Bool | true | Enable new numscript interpreter | | payments.encryption-key | string | | Payments data encryption key | | payments.worker.temporal-max-concurrent-workflow-task-pollers | Int | | Payments worker max concurrent workflow task pollers configuration | +| payments.worker.temporal-max-concurrent-activity-task-pollers | Int | | Payments worker max concurrent activity task pollers configuration | | deployments.``.init-containers.``.resource-requirements | Map | cpu=X, mem=X | | | deployments.``.containers.``.resource-requirements | Map | cpu=X, mem=X | | | deployments.``.init-containers.``.run-as | Map | user=X, group=X | | diff --git a/internal/resources/payments/deployments.go b/internal/resources/payments/deployments.go index aee68adc..d9604a76 100644 --- a/internal/resources/payments/deployments.go +++ b/internal/resources/payments/deployments.go @@ -85,8 +85,14 @@ func temporalEnvVars(ctx core.Context, stack *v1beta1.Stack, payments *v1beta1.P return nil, err } + temporalMaxConcurrentActivityTaskPollers, err := settings.GetIntOrDefault(ctx, stack.Name, 4, "payments", "worker", "temporal-max-concurrent-activity-task-pollers") + if err != nil { + return nil, err + } + env = append(env, core.Env("TEMPORAL_MAX_CONCURRENT_WORKFLOW_TASK_POLLERS", fmt.Sprintf("%d", temporalMaxConcurrentWorkflowTaskPollers)), + core.Env("TEMPORAL_MAX_CONCURRENT_ACTIVITY_TASK_POLLERS", fmt.Sprintf("%d", temporalMaxConcurrentActivityTaskPollers)), ) return env, nil