start and shutdown crons in adhoc flow (#741)

lyft · Apr 1, 2024 · a3ae577 · a3ae577
1 parent 4b99dfc
commit a3ae577
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server/neptune/adhoc/server.go b/server/neptune/adhoc/server.go
@@ -224,6 +224,10 @@ func (s Server) Start() error {
 
 	ctx := context.Background()
 
+	for _, cron := range s.Crons {
+		s.CronScheduler.Schedule(cron)
+	}
+
 	var wg sync.WaitGroup
 
 	wg.Add(1)
@@ -273,6 +277,7 @@ func (s Server) shutdown() {
 		s.Logger.Error(err.Error())
 	}
 
+	s.CronScheduler.Shutdown(5 * time.Second)
 	s.Logger.Close()
 }