diff --git a/nomad/leader.go b/nomad/leader.go index f09825d2378d..10a386d1dd04 100644 --- 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 }