fix: prevent segvault if enable-job-taggers option is tru but tagger config directories are missing

Entire-Checkpoint: 9ec86e3669e1
This commit is contained in:
2026-03-11 07:50:53 +01:00
parent 282197ebef
commit dc7407d0f0

View File

@@ -67,18 +67,20 @@ type JobTagger struct {
func newTagger() { func newTagger() {
jobTagger = &JobTagger{} jobTagger = &JobTagger{}
jobTagger.startTaggers = make([]Tagger, 0) jobTagger.startTaggers = make([]Tagger, 0)
jobTagger.startTaggers = append(jobTagger.startTaggers, &AppTagger{})
jobTagger.stopTaggers = make([]Tagger, 0) jobTagger.stopTaggers = make([]Tagger, 0)
jobTagger.stopTaggers = append(jobTagger.stopTaggers, &JobClassTagger{})
for _, tagger := range jobTagger.startTaggers { for _, t := range []Tagger{&AppTagger{}} {
if err := tagger.Register(); err != nil { if err := t.Register(); err != nil {
cclog.Errorf("failed to register start tagger: %s", err) cclog.Errorf("failed to register start tagger: %s", err)
} else {
jobTagger.startTaggers = append(jobTagger.startTaggers, t)
} }
} }
for _, tagger := range jobTagger.stopTaggers { for _, t := range []Tagger{&JobClassTagger{}} {
if err := tagger.Register(); err != nil { if err := t.Register(); err != nil {
cclog.Errorf("failed to register stop tagger: %s", err) cclog.Errorf("failed to register stop tagger: %s", err)
} else {
jobTagger.stopTaggers = append(jobTagger.stopTaggers, t)
} }
} }
} }