Skip to content

Commit

Permalink
Addon selected when kind specified even when addon defined. The kind …
Browse files Browse the repository at this point in the history
…takes precidence.

Signed-off-by: Jeff Ortel <[email protected]>
  • Loading branch information
jortel committed Jun 12, 2024
1 parent 111c36b commit 6af6fc4
Showing 1 changed file with 28 additions and 28 deletions.
56 changes: 28 additions & 28 deletions task/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -431,41 +431,41 @@ func (m *Manager) selectAddons(list []*Task) (kept []*Task, err error) {

// selectAddon select an addon when not specified.
func (m *Manager) selectAddon(task *Task) (addon *crd.Addon, err error) {
if task.Addon != "" {
found := false
addon, found = m.cluster.addons[task.Addon]
if task.Kind != "" {
kind, found := m.cluster.tasks[task.Kind]
if !found {
err = &AddonNotFound{task.Addon}
}
return
}
kind, found := m.cluster.tasks[task.Kind]
if !found {
err = &KindNotFound{task.Kind}
return
}
matched := false
var selected *crd.Addon
selector := NewSelector(m.DB, task)
for _, addon = range m.cluster.addons {
if addon.Spec.Task != kind.Name {
continue
}
matched, err = selector.Match(addon.Spec.Selector)
if err != nil {
err = &KindNotFound{task.Kind}
return
}
if matched {
selected = addon
break
matched := false
var selected *crd.Addon
selector := NewSelector(m.DB, task)
for _, addon = range m.cluster.addons {
if addon.Spec.Task != kind.Name {
continue
}
matched, err = selector.Match(addon.Spec.Selector)
if err != nil {
return
}
if matched {
selected = addon
break
}
}
if selected != nil {
task.Addon = selected.Name
task.Event(AddonSelected, selected)
}
}
if selected == nil {
err = &AddonNotSelected{}
if task.Addon != "" {
_, found := m.cluster.addons[task.Addon]
if !found {
err = &AddonNotFound{task.Addon}
}
return
}
task.Addon = selected.Name
task.Event(AddonSelected, selected)
err = &AddonNotSelected{}
return
}

Expand Down

0 comments on commit 6af6fc4

Please sign in to comment.