From 83d53ea98cf5486f89bd4280b6b5ef835da4fd22 Mon Sep 17 00:00:00 2001 From: George Goldberg Date: Tue, 11 Jul 2017 09:09:15 +0100 Subject: PLT-6475: Elasticsearch Indexing Worker. (#6879) --- jobs/jobs_watcher.go | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'jobs/jobs_watcher.go') diff --git a/jobs/jobs_watcher.go b/jobs/jobs_watcher.go index ada957ccc..5979d6207 100644 --- a/jobs/jobs_watcher.go +++ b/jobs/jobs_watcher.go @@ -79,6 +79,13 @@ func (watcher *Watcher) PollAndNotify() { default: } } + } else if js.Type == model.JOB_TYPE_SEARCH_INDEXING { + if watcher.workers.ElasticsearchIndexing != nil { + select { + case watcher.workers.ElasticsearchIndexing.JobChannel() <- j: + default: + } + } } } } -- cgit v1.2.3-1-g7c22