Replace delete_by_query with bulk delete (cleanup)

This commit is contained in:
Simon 2018-11-18 11:07:34 -05:00
parent 2f6ae3cb35
commit 64ce9379c3

View File

@ -112,12 +112,6 @@ class ElasticSearchEngine(SearchEngine):
def ping(self): def ping(self):
return self.es.ping() return self.es.ping()
@staticmethod
def batch(iterable, n=1):
l = len(iterable)
for ndx in range(0, l, n):
yield iterable[ndx:min(ndx + n, l)]
def delete_docs(self, website_id): def delete_docs(self, website_id):
try: try: