leader wip

a4c739b4 · Drew Bailey · bd25f685 · a4c739b4
Unverified Commit a4c739b4 authored 4 years ago by Drew Bailey
Hide whitespace changes
Inline Side-by-side

Showing

with 4 additions and 0 deletions
+4 -0
--- a/nomad/leader.go
+++ b/nomad/leader.go
@@ -853,6 +853,10 @@ func (s *Server) publishJobStatusMetrics(stopCh chan struct{}) {
 }

 func (s *Server) publishEventsForSinks(stopCh chan struct{}) {
+	broker, err := s.State().EventBroker()
+	if err != nil {
+		s.logger.Warn("event broker not enabled on leader", "error", err)
+	}

 	for {
 		select {