From da6c10433d90222ba3d89595c64dcbf7a02e355d Mon Sep 17 00:00:00 2001 From: Aditya <60684641+0x0elliot@users.noreply.github.com> Date: Wed, 25 Feb 2026 20:20:18 +0530 Subject: [PATCH 1/2] fix: normalize environment casing in workflow actions and triggers --- db-connector.go | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/db-connector.go b/db-connector.go index 0ced28fa..4ad1d0d0 100755 --- a/db-connector.go +++ b/db-connector.go @@ -3413,7 +3413,7 @@ func GetWorkflow(ctx context.Context, id string, skipHealth ...bool) (*Workflow, return workflow, nil } } else { - if debug { + if debug { log.Printf("[DEBUG] Failed getting cache for workflow: %s", err) } } @@ -9121,6 +9121,19 @@ func SetWorkflow(ctx context.Context, workflow Workflow, id string, optionalEdit workflow = FixWorkflowPosition(ctx, workflow) + for actionIndex, action := range workflow.Actions { + if strings.ToLower(action.Environment) == "cloud" && action.Environment != "cloud" { + workflow.Actions[actionIndex].Environment = "cloud" + log.Printf("[INFO] Normalized action environment from '%s' to 'cloud' in workflow %s", action.Environment, workflow.ID) + } + } + for triggerIndex, trigger := range workflow.Triggers { + if strings.ToLower(trigger.Environment) == "cloud" && trigger.Environment != "cloud" { + workflow.Triggers[triggerIndex].Environment = "cloud" + log.Printf("[INFO] Normalized trigger environment from '%s' to 'cloud' in workflow %s", trigger.Environment, workflow.ID) + } + } + // New struct, to not add body, author etc data, err := json.Marshal(workflow) if err != nil { From 5f0765240d602f9494c7cc0328962a9257976b28 Mon Sep 17 00:00:00 2001 From: Aditya <60684641+0x0elliot@users.noreply.github.com> Date: Fri, 27 Feb 2026 04:33:49 +0530 Subject: [PATCH 2/2] fix: condition normalization logging on debug flag --- db-connector.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/db-connector.go b/db-connector.go index 4ad1d0d0..62c350cb 100755 --- a/db-connector.go +++ b/db-connector.go @@ -9123,14 +9123,18 @@ func SetWorkflow(ctx context.Context, workflow Workflow, id string, optionalEdit for actionIndex, action := range workflow.Actions { if strings.ToLower(action.Environment) == "cloud" && action.Environment != "cloud" { + if debug { + log.Printf("[DEBUG] Normalized action environment from '%s' to 'cloud' in workflow %s", action.Environment, workflow.ID) + } workflow.Actions[actionIndex].Environment = "cloud" - log.Printf("[INFO] Normalized action environment from '%s' to 'cloud' in workflow %s", action.Environment, workflow.ID) } } for triggerIndex, trigger := range workflow.Triggers { if strings.ToLower(trigger.Environment) == "cloud" && trigger.Environment != "cloud" { + if debug { + log.Printf("[DEBUG] Normalized trigger environment from '%s' to 'cloud' in workflow %s", trigger.Environment, workflow.ID) + } workflow.Triggers[triggerIndex].Environment = "cloud" - log.Printf("[INFO] Normalized trigger environment from '%s' to 'cloud' in workflow %s", trigger.Environment, workflow.ID) } }