diff --git a/app.py b/app.py index f99417c..8e97e13 100644 --- a/app.py +++ b/app.py @@ -36,6 +36,7 @@ app.jinja_env.globals.update(get_mime=od_util.get_category) taskManager = TaskManager() searchEngine = ElasticSearchEngine("od-database") +searchEngine.start_stats_scheduler() @app.template_filter("date_format") diff --git a/search/search.py b/search/search.py index fe7b85d..5555b03 100644 --- a/search/search.py +++ b/search/search.py @@ -50,12 +50,14 @@ class ElasticSearchEngine(SearchEngine): self.index_name = index_name self.es = elasticsearch.Elasticsearch() + if not self.es.indices.exists(self.index_name): + self.init() + + def start_stats_scheduler(self): scheduler = BackgroundScheduler() scheduler.add_job(self._generate_global_stats, "interval", seconds=60 * 120) scheduler.start() - if not self.es.indices.exists(self.index_name): - self.init() def init(self): print("Elasticsearch first time setup")