Run deployment garbage collector on an interval

Fixes #3244
hashicorp · Sep 25, 2017 · 5db4f4c · 5db4f4c
1 parent 5c44105
commit 5db4f4c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/nomad/leader.go b/nomad/leader.go
@@ -363,6 +363,8 @@ func (s *Server) schedulePeriodic(stopCh chan struct{}) {
 	defer nodeGC.Stop()
 	jobGC := time.NewTicker(s.config.JobGCInterval)
 	defer jobGC.Stop()
+	deploymentGC := time.NewTicker(s.config.DeploymentGCInterval)
+	defer deploymentGC.Stop()
 
 	// getLatest grabs the latest index from the state store. It returns true if
 	// the index was retrieved successfully.
@@ -391,6 +393,10 @@ func (s *Server) schedulePeriodic(stopCh chan struct{}) {
 			if index, ok := getLatest(); ok {
 				s.evalBroker.Enqueue(s.coreJobEval(structs.CoreJobJobGC, index))
 			}
+		case <-deploymentGC.C:
+			if index, ok := getLatest(); ok {
+				s.evalBroker.Enqueue(s.coreJobEval(structs.CoreJobDeploymentGC, index))
+			}
 		case <-stopCh:
 			return
 		}