fix(scheduler): keep scheduler process running
This commit is contained in:
@@ -21,5 +21,5 @@ func main() {
|
|||||||
datasetScheduler := crontab.NewDatasetScheduler(datasetService, log.Default())
|
datasetScheduler := crontab.NewDatasetScheduler(datasetService, log.Default())
|
||||||
schedulerContext, stopScheduler := context.WithCancel(context.Background())
|
schedulerContext, stopScheduler := context.WithCancel(context.Background())
|
||||||
defer stopScheduler()
|
defer stopScheduler()
|
||||||
go datasetScheduler.Run(schedulerContext)
|
datasetScheduler.Run(schedulerContext)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user