initial implementation #1

Merged
lerentis merged 7 commits from init into main 2023-11-04 11:17:41 +00:00
2 changed files with 4 additions and 3 deletions
Showing only changes of commit b0577f3c55 - Show all commits

View File

@ -33,7 +33,7 @@ type PendingInformation struct {
ID int `json:"id"`
Data string `json:"data"`
Labels map[string]string `json:"labels"`
Dependencies string `json:"dependencies"`
Dependencies string `json:"dependencies,omitempty"`
RunOn string `json:"run_on"`
DepStatus string `json:"-"` // dont need those
AgentId int `json:"agent_id"`
@ -48,9 +48,9 @@ type Stats struct {
}
type QueueInfo struct {
Pending []PendingInformation `json:"pending"`
Pending []PendingInformation `json:"pending,omitempty"`
WaitingOnDeps string `json:"-"` // dont need those
Running int `json:"running"`
Running int `json:"running,omitempty"`
Stats Stats `json:"stats"`
Paused bool `json:"paused"`
}

View File

@ -41,6 +41,7 @@ func CheckPending(cfg *config.Config) error {
return errors.New(fmt.Sprintf("Error from QueueInfo: %s", err.Error()))
}
if queueInfo.Stats.PendingCount > 0 {
// TODO: queueInfo.Pending may be empty
for _, pendingJobs := range queueInfo.Pending {
// TODO: separate key and value from LabelSelector and compare them deeply
_, exists := pendingJobs.Labels[cfg.LabelSelector]