TP-89230 | hotfix for ameyo integration
This commit is contained in:
@@ -32,7 +32,7 @@ func NewJobScheduler(logger *log.Logger, elasticSearchClient *elastic.ElasticSea
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *JobScheduler) ScheduleEsCleanUpJob() {
|
func (s *JobScheduler) ScheduleEsCleanUpJob() {
|
||||||
s.scheduler.NewJob(gocron.DurationJob(2*time.Second), gocron.NewTask(esCleanUpJob, s))
|
s.scheduler.NewJob(gocron.DurationJob(2*time.Hour), gocron.NewTask(esCleanUpJob, s))
|
||||||
}
|
}
|
||||||
func esCleanUpJob(s *JobScheduler) {
|
func esCleanUpJob(s *JobScheduler) {
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user