chore: safety update queue lables

2024-07-07 09:59:48 +08:00 · 2024-07-07 09:59:48 +08:00 · 8cbd35ed0a
parent b5cc208dec
commit 8cbd35ed0a
1 changed files with 2 additions and 2 deletions
--- a/plugin/api/alerting/rule.go
+++ b/plugin/api/alerting/rule.go
@ -325,12 +325,12 @@ func (alertAPI *AlertAPI) getRuleDetail(w http.ResponseWriter, req *http.Request
 func saveActivity(activityInfo *event.Activity){
 	queueConfig := queue.GetOrInitConfig("platform##activities")
 	if queueConfig.Labels == nil {
-		queueConfig.Labels = util.MapStr{
+		queueConfig.ReplaceLabels(util.MapStr{
 			"type":     "platform",
 			"name":     "activity",
 			"category": "elasticsearch",
 			"activity": true,
-		}
+		})
 	}
 	err := queue.Push(queueConfig, util.MustToJSONBytes(event.Event{
 		Timestamp: time.Now(),