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

Orborus rerun fix for run/swarm

Browse Source
This commit is contained in:
Frikky
2023-10-23 01:20:35 +02:00
parent 0a952a6e0b
commit 96f972d465
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/orborus/orborus.go
+5 -5
View File
@@ -1198,8 +1198,6 @@ func main() {
//sigCh := make(chan os.Signal, 1) //sigCh := make(chan os.Signal, 1)
//signal.Notify(sigCh, os.Interrupt, syscall.SIGTERM) //signal.Notify(sigCh, os.Interrupt, syscall.SIGTERM)
//defer cleanup() //defer cleanup()
//sig := <-sigCh
//log.Printf("[INFO] Received signal %s. Exiting.", sig)
// Block until a signal is received // Block until a signal is received
if isRunningInCluster() { if isRunningInCluster() {
@@ -1510,13 +1508,15 @@ func main() {
} }
if shuffle.ArrayContains(executionIds, execution.ExecutionId) { if shuffle.ArrayContains(executionIds, execution.ExecutionId) {
log.Printf("[INFO] Execution already handled (rerun of old executions): %s", execution.ExecutionId) log.Printf("[INFO] Execution already handled (rerun of old executions?): %s", execution.ExecutionId)
toBeRemoved.Data = append(toBeRemoved.Data, execution) toBeRemoved.Data = append(toBeRemoved.Data, execution)
continue
if swarmConfig != "run" && swarmConfig != "swarm" {
continue
}
} }
// Now, how do I execute this one? // Now, how do I execute this one?
// FIXME - if error, check the status of the running one. If it's bad, send data back.
containerName := fmt.Sprintf("worker-%s", execution.ExecutionId) containerName := fmt.Sprintf("worker-%s", execution.ExecutionId)
env := []string{ env := []string{
fmt.Sprintf("AUTHORIZATION=%s", execution.Authorization), fmt.Sprintf("AUTHORIZATION=%s", execution.Authorization),