func (jq *jobQueue) run(s *Scheduler) {

	go func() {
		log.Debugf("Job queue is running...")
		for jq.process(s) {
			// empty
		}
		jq.stopped <- true
	}()
}
// run schedules the checks in the queue by posting them to the
// execution pipeline.
// Not blocking, runs in a new goroutine.
run schedules the checks in the queue by posting them to the
execution pipeline.
Not blocking, runs in a new goroutine.
// run schedules the checks in the queue by posting them to the // execution pipeline . // Not blocking runs in a new goroutine .
func (jq *jobQueue) run(s *Scheduler) {
	go func() {
		log.Debugf("Job queue is running...")
		for jq.process(s) {
		}
		jq.stopped <- true
	}()
}
func ( jq * jobQueue ) run ( s * Scheduler ) { go func ( ) { log . Debugf ( " " ) for jq . process ( s ) { } jq . stopped <- true } ( ) }
run schedules the checks in the queue by posting them to the
execution pipeline.
run schedules the checks in the queue by posting them to the execution pipeline .
// empty