Fixes rescheduling on boltdb store

distribworks · Dec 11, 2018 · ea5e60b · ea5e60b
1 parent b0254ac
commit ea5e60b
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/dkron/queries.go b/dkron/queries.go
@@ -131,7 +131,14 @@ func (a *Agent) RunQuery(ex *Execution) {
 func (a *Agent) SchedulerRestart() {
 	if rescheduleThrotle == nil {
 		rescheduleThrotle = time.AfterFunc(rescheduleTime, func() {
+			// In case we are using BoltDB we just need to reschedule because
+			// there is no leader nor other nodes.
+			// In case of using any other engine send the scheduler restart query.
+			if a.config.Backend == store.BOLTDB {
+				a.schedule()
+			} else {
 			a.schedulerRestartQuery(string(a.Store.GetLeader()))
+			}
 		})
 	} else {
 		rescheduleThrotle.Reset(rescheduleTime)