From 9ff21e79436bce61cc6f9c45ff71c957f84ae35c Mon Sep 17 00:00:00 2001 From: Simon Date: Thu, 28 Jun 2018 22:47:14 -0400 Subject: [PATCH] Fixed indentation error --- search/search.py | 60 ++++++++++++++++++++++++------------------------ 1 file changed, 30 insertions(+), 30 deletions(-) diff --git a/search/search.py b/search/search.py index 7ef7607..00fa03f 100644 --- a/search/search.py +++ b/search/search.py @@ -406,39 +406,39 @@ class ElasticSearchEngine(SearchEngine): return stats -def stream_all_docs(self): - return helpers.scan(query={ - "query": { - "match_all": {} - } - }, scroll="5m", client=self.es, index=self.index_name) + def stream_all_docs(self): + return helpers.scan(query={ + "query": { + "match_all": {} + } + }, scroll="5m", client=self.es, index=self.index_name) -def are_empty(self, websites): - result = self.es.search(body={ - "query": { - "bool": { - "filter": { + def are_empty(self, websites): + result = self.es.search(body={ + "query": { + "bool": { + "filter": { + "terms": { + "website_id": websites + }, + } + } + }, + "aggs": { + "websites": { "terms": { - "website_id": websites - }, + "field": "website_id", + "size": 100000, + "min_doc_count": 1 + } } - } - }, - "aggs": { - "websites": { - "terms": { - "field": "website_id", - "size": 100000, - "min_doc_count": 1 - } - } - }, - "size": 0 - }, index=self.index_name, request_timeout=30) + }, + "size": 0 + }, index=self.index_name, request_timeout=30) - non_empty_websites = [bucket["key"] for bucket in result["aggregations"]["websites"]["buckets"]] + non_empty_websites = [bucket["key"] for bucket in result["aggregations"]["websites"]["buckets"]] - for website in websites: - if website not in non_empty_websites: - yield website + for website in websites: + if website not in non_empty_websites: + yield website