diff options
Diffstat (limited to 'jobs/workers.go')
| -rw-r--r-- | jobs/workers.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/jobs/workers.go b/jobs/workers.go index dfa150ff6..c984a43b8 100644 --- a/jobs/workers.go +++ b/jobs/workers.go @@ -27,8 +27,8 @@ func (srv *JobServer) InitWorkers() *Workers { workers := &Workers{} workers.Watcher = srv.MakeWatcher(workers, DEFAULT_WATCHER_POLLING_INTERVAL) - if dataRetentionInterface := srv.DataRetention; dataRetentionInterface != nil { - workers.DataRetention = dataRetentionInterface.MakeWorker() + if srv.DataRetentionJob != nil { + workers.DataRetention = srv.DataRetentionJob.MakeWorker() } if elasticsearchIndexerInterface := srv.ElasticsearchIndexer; elasticsearchIndexerInterface != nil { |