marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

worker never gets the env it is suppose to run so we should just check for our reserved env name

Browse Source
This commit is contained in:
yashsinghcodes
2026-01-28 17:50:53 +05:30
parent fae82b3b61
commit a8b17515d8
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/worker/worker.go
+3 -1
View File
@@ -2669,7 +2669,9 @@ func handleWorkflowQueue(resp http.ResponseWriter, request *http.Request) {
} }
} }
if strings.EqualFold(actionResult.Action.Environment, environment) && len(environment) > 0 && len(actionResult.Action.Environment) > 0 { // Not doing environment as we don't want to hook a worker to specific env. It should just not handle cloud actions
// limiting a worker to an env will not allow us to run multiple orborus in the same server?
if strings.EqualFold(actionResult.Action.Environment, "cloud") {
log.Printf("[WARNING] Got an action for %s environment forwarding it to the backend", actionResult.Action.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) streamUrl := fmt.Sprintf("%s/api/v1/streams", baseUrl)