Quellcode durchsuchen

feat(alerting): do not enqueue paused rules

bergquist vor 9 Jahren
Ursprung
Commit
19427b59f9
1 geänderte Dateien mit 2 neuen und 1 gelöschten Zeilen
  1. 2 1
      pkg/services/alerting/scheduler.go

+ 2 - 1
pkg/services/alerting/scheduler.go

@@ -5,6 +5,7 @@ import (
 	"time"
 	"time"
 
 
 	"github.com/grafana/grafana/pkg/log"
 	"github.com/grafana/grafana/pkg/log"
+	"github.com/grafana/grafana/pkg/models"
 )
 )
 
 
 type SchedulerImpl struct {
 type SchedulerImpl struct {
@@ -48,7 +49,7 @@ func (s *SchedulerImpl) Tick(tickTime time.Time, execQueue chan *Job) {
 	now := tickTime.Unix()
 	now := tickTime.Unix()
 
 
 	for _, job := range s.jobs {
 	for _, job := range s.jobs {
-		if job.Running {
+		if job.Running || job.Rule.State == models.AlertStatePaused {
 			continue
 			continue
 		}
 		}