add collect job label to charts (#814)

netdata · Sep 8, 2022 · d248e30 · d248e30
1 parent cd2cff4
commit d248e30
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/agent/module/job.go b/agent/module/job.go
@@ -378,6 +378,7 @@ func (j *Job) createChart(chart *Chart) {
 	if chart.ignore {
 		return
 	}
+	j.addJobNameLabel(chart)
 
 	if chart.Priority == 0 {
 		chart.Priority = j.priority
@@ -483,6 +484,22 @@ func (j *Job) updateChart(chart *Chart, collected map[string]int64, sinceLastRun
 	return chart.updated
 }
 
+func (j Job) addJobNameLabel(chart *Chart) {
+	const lblKey = "_collect_job"
+	var ok bool
+	for _, lbl := range chart.Labels {
+		if ok = lbl.Key == lblKey; ok {
+			break
+		}
+	}
+	if !ok {
+		chart.Labels = append(chart.Labels, Label{
+			Key:   lblKey,
+			Value: j.Name(),
+		})
+	}
+}
+
 func (j Job) penalty() int {
 	v := j.retries / penaltyStep * penaltyStep * j.updateEvery / 2
 	if v > maxPenalty {