From 8c2731b328683a7492a4aefbeab7a90679d97064 Mon Sep 17 00:00:00 2001 From: Jose Diaz-Gonzalez Date: Mon, 27 Oct 2025 14:37:13 -0400 Subject: [PATCH] fix: properly set concurrency policy for golang --- plugins/scheduler-k3s/triggers.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/plugins/scheduler-k3s/triggers.go b/plugins/scheduler-k3s/triggers.go index 1086a7163..7ae406ee4 100644 --- a/plugins/scheduler-k3s/triggers.go +++ b/plugins/scheduler-k3s/triggers.go @@ -700,6 +700,16 @@ func TriggerSchedulerDeploy(scheduler string, appName string, imageTag string) e } concurrencyPolicy := strings.ToUpper(cronTask.ConcurrencyPolicy) + switch concurrencyPolicy { + case "ALLOW": + concurrencyPolicy = "Allow" + case "FORBID": + concurrencyPolicy = "Forbid" + case "REPLACE": + concurrencyPolicy = "Replace" + default: + return fmt.Errorf("Invalid concurrency_policy specified: %v", concurrencyPolicy) + } processValues := ProcessValues{ Args: words, Annotations: annotations,