summaryrefslogtreecommitdiffstats
path: root/jobs/schedulers.go
diff options
context:
space:
mode:
authorGeorge Goldberg <george@gberg.me>2017-10-02 12:43:21 +0100
committerGitHub <noreply@github.com>2017-10-02 12:43:21 +0100
commit76bd1bb212177824379c485c553e54530a854009 (patch)
treef4b3c41ff3ff72c96ab58e944e4254bfca4fd8be /jobs/schedulers.go
parent9bc7af0c5704bbf73f8240b4569d5ea215352e39 (diff)
downloadchat-76bd1bb212177824379c485c553e54530a854009.tar.gz
chat-76bd1bb212177824379c485c553e54530a854009.tar.bz2
chat-76bd1bb212177824379c485c553e54530a854009.zip
PLT-7705: API to get data retention policy. (#7539)
* PLT-7705: API to get data retention policy. * Fix review comments.
Diffstat (limited to 'jobs/schedulers.go')
-rw-r--r--jobs/schedulers.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/jobs/schedulers.go b/jobs/schedulers.go
index 2f1ae394f..3d52c969a 100644
--- a/jobs/schedulers.go
+++ b/jobs/schedulers.go
@@ -35,8 +35,8 @@ func (srv *JobServer) InitSchedulers() *Schedulers {
jobs: srv,
}
- if dataRetentionInterface := srv.DataRetention; dataRetentionInterface != nil {
- schedulers.schedulers = append(schedulers.schedulers, dataRetentionInterface.MakeScheduler())
+ if srv.DataRetentionJob != nil {
+ schedulers.schedulers = append(schedulers.schedulers, srv.DataRetentionJob.MakeScheduler())
}
if elasticsearchAggregatorInterface := srv.ElasticsearchAggregator; elasticsearchAggregatorInterface != nil {