Try to fix scheduler not starting (#1053)

Fixes #998

dkron/leader.go

@@ -144,6 +144,10 @@ WAIT:
 // membership and what is reflected in our strongly consistent store.
 func (a *Agent) reconcile() error {
 	defer metrics.MeasureSince([]string{"dkron", "leader", "reconcile"}, time.Now())
+
+	// TODO: Try to fix https://github.com/distribworks/dkron/issues/998
+	a.sched.Cron.Start()
+
 	members := a.serf.Members()
 	for _, member := range members {
 		if err := a.reconcileMember(member); err != nil {

dkron/scheduler.go

@@ -77,7 +77,7 @@ func (s *Scheduler) Stop() {
 
 	if s.started {
 		s.logger.Debug("scheduler: Stopping scheduler")
-		<- s.Cron.Stop().Done()
+		<-s.Cron.Stop().Done()
 		s.started = false
 		// Keep Cron exists and let the jobs which have been scheduled can continue to finish,
 		// even the node's leadership will be revoked.
@@ -96,7 +96,9 @@ func (s *Scheduler) Stop() {
 func (s *Scheduler) Restart(jobs []*Job, agent *Agent) {
 	s.Stop()
 	s.ClearCron()
-	s.Start(jobs, agent)
+	if err := s.Start(jobs, agent); err != nil {
+		s.logger.Fatal(err)
+	}
 }
 
 // Clear cron separately, this can only be called when agent will be stop.
@@ -163,7 +165,7 @@ func (s *Scheduler) AddJob(job *Job) error {
 	return nil
 }
 
-// RemoveJob removes a job from the cron scheduler
+// RemoveJob removes a job from the cron scheduler if it exists.
 func (s *Scheduler) RemoveJob(job *Job) {
 	s.logger.WithFields(logrus.Fields{
 		"job": job.Name,