From ed6417b9be769951b14a53ccc5fe22e48fd0965f Mon Sep 17 00:00:00 2001 From: yashsinghcodes Date: Tue, 13 Jan 2026 17:46:47 +0530 Subject: [PATCH] added check for environment in handleQueue worker --- functions/onprem/worker/worker.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go index 939f8bee..0bd8ba1c 100644 --- a/functions/onprem/worker/worker.go +++ b/functions/onprem/worker/worker.go @@ -2652,8 +2652,7 @@ func handleWorkflowQueue(resp http.ResponseWriter, request *http.Request) { } } - if strings.ToLower(actionResult.Action.Environment) == "cloud" { - + if strings.ToLower(actionResult.Action.Environment) != environment { log.Printf("[WARNING] Got an action for %s environment forwarding it to the backend", actionResult.Action.Environment) streamUrl := fmt.Sprintf("%s/api/v1/streams", baseUrl)