covidnetes/woodpecker-autoscaler
4
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases 3 Wiki Activity

handle empty queue
All checks were successful
Pipeline was successful
Details

Browse Source
This commit is contained in:
Tobias Trabelsi 2023-11-08 20:42:20 +01:00
parent 089df0ff7f
commit bbaa89d4c2
Signed by: lerentis
GPG Key ID: FF0C2839718CAF2E
1 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
cmd/woodpecker-autoscaler.go
View File

@ -86,23 +86,29 @@ func main() {
"Caller": "Main", "Caller": "Main",
}).Fatal(fmt.Sprintf("Error checking woodpecker queue: %s", err.Error())) }).Fatal(fmt.Sprintf("Error checking woodpecker queue: %s", err.Error()))
} }
if runningTasks <= len(ownedNodes) { if runningTasks <= len(ownedNodes) && runningTasks != 0 {
log.WithFields(log.Fields{ log.WithFields(log.Fields{
"Caller": "Main", "Caller": "Main",
}).Info("Still found running tasks. No agent to be removed") }).Info("Still found running tasks. No agent to be removed")
} else { } else {
log.WithFields(log.Fields{ if len(ownedNodes) == 0 {
"Caller": "Main", log.WithFields(log.Fields{
}).Info("No tasks running. Will remove agents") "Caller": "Main",
for _, server := range ownedNodes { }).Infof("Nothing running and not owning any nodes. Recheck in %d", cfg.CheckInterval)
hetzner.DecomNode(cfg, &server) } else {
agentId, err := woodpecker.GetAgentIdByName(cfg, server.Name) log.WithFields(log.Fields{
if err != nil { "Caller": "Main",
log.WithFields(log.Fields{ }).Info("No tasks running. Will remove agents")
"Caller": "Main", for _, server := range ownedNodes {
}).Warnf("Could not find agent %s in woodpecker. Assuming it was never added", server.Name) hetzner.DecomNode(cfg, &server)
} else { agentId, err := woodpecker.GetAgentIdByName(cfg, server.Name)
woodpecker.DecomAgent(cfg, agentId) if err != nil {
log.WithFields(log.Fields{
"Caller": "Main",
}).Warnf("Could not find agent %s in woodpecker. Assuming it was never added", server.Name)
} else {
woodpecker.DecomAgent(cfg, agentId)
}
} }
} }
} }