diff options
Diffstat (limited to 'jobs/schedulers.go')
| -rw-r--r-- | jobs/schedulers.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/jobs/schedulers.go b/jobs/schedulers.go index cbe5f1749..bec53a49b 100644 --- a/jobs/schedulers.go +++ b/jobs/schedulers.go @@ -39,6 +39,10 @@ func (srv *JobServer) InitSchedulers() *Schedulers { schedulers.schedulers = append(schedulers.schedulers, srv.DataRetentionJob.MakeScheduler()) } + if srv.MessageExportJob != nil { + schedulers.schedulers = append(schedulers.schedulers, srv.MessageExportJob.MakeScheduler()) + } + if elasticsearchAggregatorInterface := srv.ElasticsearchAggregator; elasticsearchAggregatorInterface != nil { schedulers.schedulers = append(schedulers.schedulers, elasticsearchAggregatorInterface.MakeScheduler()) } |