fix: wait all jobs done (#1010)

Signed-off-by: KevinWu0904 <[email protected]>
distribworks · Aug 26, 2021 · f5c9553 · f5c9553
1 parent 6e1246c
commit f5c9553
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dkron/scheduler.go b/dkron/scheduler.go
@@ -77,7 +77,7 @@ func (s *Scheduler) Stop() {
 
 	if s.started {
 		s.logger.Debug("scheduler: Stopping scheduler")
-		s.Cron.Stop()
+		<- 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.